Type Alias SinkCallback

SinkCallback: (
iterator: AsyncIterableIterator<sink.Datum>,
) => Promise<sink.Response[]>

Callback function type for sink handlers. Receives an async iterator of datums and returns an array of responses.

Type Declaration

- (iterator: AsyncIterableIterator<sink.Datum>): Promise<sink.Response[]>
- Parameters
  - iterator: AsyncIterableIterator<sink.Datum>
  Returns Promise<sink.Response[]>