Class AsyncServer

Example

const server = new sourceTransform.AsyncServer(async (datum) => {
  // Parse JSON and extract timestamp
  const data = JSON.parse(datum.value.toString());
  const eventTime = new Date(data.timestamp);

  // Return transformed message with new event time
  return [new sourceTransform.Message(datum.value, eventTime)];
});

// Start the server
await server.start();

// Later, stop the server gracefully
server.stop();
Copy