Type Alias CallbackFn

CallbackFn: (
    keys: string[],
    iterator: AsyncIterableIterator<reduceStream.Datum>,
    metadata: reduceStream.Metadata,
) => AsyncIterable<reduceStream.Message>

Callback function type for reduce stream handlers. Returns an async iterable of output messages.

Type Declaration

- (
      keys: string[],
      iterator: AsyncIterableIterator<reduceStream.Datum>,
      metadata: reduceStream.Metadata,
  ): AsyncIterable<reduceStream.Message>
- Parameters
  - keys: string[]
  - iterator: AsyncIterableIterator<reduceStream.Datum>
  - metadata: reduceStream.Metadata
  Returns AsyncIterable<reduceStream.Message>