streamReducer

streamReducer<S, D>(params): AsyncIterable<S>

Defined in: packages/core/src/utils/index.ts:45

Type Parameters

S

S

D

D

Parameters

params

stream

AsyncIterable<S>

reducer

(previousValue, currentValue) => D

initialValue

D

finished?

(value) => void

Returns

AsyncIterable<S>