import { type AsyncStreamConstructors } from "https://deno.land/x/rimbu@1.1.0/stream/async-custom/constructors.ts";
Methods
Returns an AsyncStream with the result of applying given zipFun
to each successive value resulting from the given sources
.
Returns an AsyncStream with tuples containing each successive value from the given sources
.
Returns an AsyncStream with the result of applying given zipFun
to each successive value resulting from the given sources
, adding
given fillValue
to any Streams that end before all streams have ended.
Returns an AsyncStream with tuples containing each successive value from the given sources
, adding given fillValue
to any streams
that end before all streams have ended.
Returns an AsyncStream concatenating the given source
AsyncStreamSource containing StreamSources.
Returns an array containing an AsyncStream for each tuple element resulting from given source
AsyncStream.
Returns a possibly infinite Stream starting with given init
value, followed by applying given next
function to the previous value.