import { AsyncStreamBase } from "https://deno.land/x/rimbu@1.1.0/stream/async-custom/async-stream-custom.ts";
Parameters
shape: S & AsyncReducer.CombineShape<T>
Returns
AsyncStream<AsyncReducer.CombineResult<S>>
x/rimbu/stream/async-custom/async-stream-custom.ts>AsyncStreamBase#reduceStream
import { AsyncStreamBase } from "https://deno.land/x/rimbu@1.1.0/stream/async-custom/async-stream-custom.ts";