Skip to main content

package @rimbu/stream/async

The @rimbu/stream/async package provides the AsyncStream implementations.

See the Rimbu docs Stream page for more information.

Interfaces

NameDescription
AsyncFastIterable<T>undocumented
AsyncFastIterator<T>An asynchronous iterator that extends the default AsyncIterator interface with methods for improved performance.
AsyncStream<T>A possibly infinite asynchronous sequence of elements of type T. See the Stream documentation and the AsyncStream API documentation
AsyncStreamable<T>Represents an object that can produce an asynchronous stream of values.

Namespaces

NameDescription
AsyncReducerAn AsyncReducer is a stand-alone asynchronous calculation that takes input values of type I, and, when requested, produces an output value of type O.
AsyncStreamA possibly infinite asynchronous sequence of elements of type T. See the Stream documentation and the AsyncStream API documentation
AsyncStreamableRepresents an object that can produce an asynchronous stream of values.
AsyncStreamSourceundocumented
AsyncTransformerAn AsyncReducer that produces instances of AsyncStreamSource.