Type Alias Callback

Callback: (
    keys: string[],
    iterator: AsyncIterableIterator<reduce.Datum>,
    metadata: reduce.Metadata,
) => Promise<reduce.Message[]>

Callback function type for reduce handlers. Receives keys, an iterator of datums, and window metadata.

Type Declaration

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