package @rimbu/stream
The @rimbu/stream package provides the Stream and AsyncStream implementations and many related utilities.
See the Rimbu docs Stream page for more information.
This package also exports everything from the the following sub-packages:
Interfaces
| Name | Description |
|---|---|
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. |
FastIterable<T> | An interface that extends the standard Iterable interface to return a FastIterator instead of a normal Iterator. |
FastIterator<T> | An iterator that extends the default Iterator interface with methods that give more performance. |
Stream<T> | A possibly infinite sequence of elements of type T. See the Stream documentation and the Stream API documentation |
Streamable<T> | An object that can create a Stream 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 | Represents an object that can produce an asynchronous stream of values. |
AsyncStreamSource | undocumented |
AsyncTransformer | An AsyncReducer that produces instances of AsyncStreamSource. |
Reducer | A Reducer is a stand-alone calculation that takes input values of type I, and, when requested, produces an output value of type O. |
Stream | A possibly infinite sequence of elements of type T. See the Stream documentation and the Stream API documentation |
Streamable | An object that can create a Stream of elements of type T. |
StreamSource | Any object that is Iterable, a Stream, or can produce a Stream. |
Transformer | A Reducer that produces instances of StreamSource. |