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:

• @rimbu/stream/async

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.
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	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.
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.