namespace AsyncStream
A possibly infinite asynchronous sequence of elements of type T. See the Stream documentation and the AsyncStream API documentation
Companion interface: AsyncStream<T>
Interfaces
Name | Description |
---|---|
AsyncStream.NonEmpty<T> | A non-empty and possibly infinite asynchronous sequence of elements of type T. See the Stream documentation and the AsyncStream API documentation |
Static Methods
always
undocumented
always
empty
undocumented
empty
flatten
Returns an AsyncStream concatenating the given source
AsyncStreamSource containing StreamSources.
flatten
source
AsyncStreamSource containing StreamSources.from
undocumented
from
fromResource
undocumented
fromResource
of
undocumented
of
unfold
Returns a possibly infinite Stream starting with given init
value, followed by applying given next
function to the previous value.
unfold
init
value, followed by applying given next
function to the previous value.unzip
Returns an array containing an AsyncStream for each tuple element resulting from given source
AsyncStream.
unzip
source
AsyncStream.zip
Returns an AsyncStream with tuples containing each successive value from the given sources
.
zip
sources
.zipAll
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.
zipAll
sources
, adding given fillValue
to any streams that end before all streams have ended.zipAllWith
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.
zipAllWith
zipFun
to each successive value resulting from the given sources
, adding given fillValue
to any Streams that end before all streams have ended.zipWith
Returns an AsyncStream with the result of applying given zipFun
to each successive value resulting from the given sources
.
zipWith
zipFun
to each successive value resulting from the given sources
.