package @rimbu/stream/async
The @rimbu/stream/async package provides the AsyncStream implementations.
See the Rimbu docs Stream page for more information.
Interfaces
| Name | Description |
|---|---|
AsyncFastIterable<T> | An interface that extends the standard AsyncIterable interface to return an AsyncFastIterator instead of a normal AsyncIterator. |
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> | An object that can create an AsyncStream of elements of type T. |
Namespaces
| Name | Description |
|---|---|
AsyncReducer | An AsyncReducer is a stand-alone asynchronous calculation that takes input values of type I, and, when requested, produces an output value of type O. |
AsyncStream | A possibly infinite asynchronous sequence of elements of type T. See the Stream documentation and the AsyncStream API documentation |
AsyncStreamable | An object that can create an AsyncStream of elements of type T. |
AsyncStreamSource | Any source that can be converted to an AsyncStream. This includes async streams, sync streams, async iterables, and lazy factories. |
AsyncTransformer | An AsyncReducer that produces instances of AsyncStreamSource. |