/stream/mod.ts | rimbu@1.0.2

import * as rimbu from "https://deno.land/x/rimbu@1.0.2/stream/mod.ts";

Namespaces

v AsyncStream
v AsyncTransformer.window	Returns an async transformer that produces windows/collections of `windowSize` size, each window starting `skipAmount` of elements after the previous, and optionally collected by a custom reducer.
v Stream
v Transformer.window	Returns a transformer that produces windows/collections of `windowSize` size, each window starting `skipAmount` of elements after the previous, and optionally collected by a custom reducer.

f AsyncTransformer.distinctPrevious	Returns an async transformer that returns only those elements from the input that are different to previous element according to the optionally given `eq` function.
f Transformer.distinctPrevious	Returns a transformer that returns only those elements from the input that are different to previous element according to the optionally given `eq` function.

I AsyncFastIterable
I AsyncFastIterator
I AsyncStream	A possibly infinite asynchronous sequence of elements of type T. See the Stream documentation and the AsyncStream API documentation
I AsyncStream.NonEmpty	A non-empty and possibly infinite asynchronous sequence of elements of type T. See the Stream documentation and the AsyncStream API documentation
I AsyncStreamable
I AsyncStreamable.NonEmpty
I FastIterable	An interface that extends the standard `Iterable` interface to return a `FastIterator` instead of a normal `Iterator`.
I FastIterator	An iterator that extends the default `Iterator` interface with methods that give more performance.
I Stream	A possibly infinite sequence of elements of type T. See the Stream documentation and the Stream API documentation
I Stream.NonEmpty	A non-empty and possibly infinite sequence of elements of type T. See the Stream documentation and the Stream API documentation
I Streamable	An object that can create a Stream of elements of type `T`.
I Streamable.NonEmpty	An object that can create a non-empty Stream of elements of type `T`.

T AsyncStreamSource
T AsyncStreamSource.NonEmpty
T AsyncTransformer	An AsyncReducer that produces instances of `AsyncStreamSource`.
T AsyncTransformer.NonEmpty	An AsyncReducer that produces instances `AsyncStreamSource.NonEmpty`.
T StreamSource	Any object that is Iterable, a Stream, or can produce a Stream.
T StreamSource.NonEmpty	Any object that is a non-empty Stream, can produce a non-empty Stream, or is a non-empty array.
T Transformer	A Reducer that produces instances of `StreamSource`.
T Transformer.NonEmpty	A Reducer that produces instances of `StreamSource.NonEmpty`.