Class AsyncServer

Example

const server = new sink.AsyncServer(async (datums) => {
  const responses = [];
  for await (const datum of datums) {
    try {
      await processMessage(datum.getValue());
      responses.push(sink.Response.ok(datum.id));
    } catch (e) {
      responses.push(sink.Response.failure(datum.id, e.message));
    }
  }
  return responses;
});
Copy