import * as rimbu from "https://deno.land/x/rimbu@0.13.5/stream/mod.ts";
Variables
Returns an async transformer that produces windows/collections of | |
Returns a transformer that produces windows/collections of |
Functions
Returns an async transformer that returns only those elements from the input that are different to previous element
according to the optionally given | |
Returns a transformer that returns only those elements from the input that are different to previous element
according to the optionally given |
Interfaces
A possibly infinite asynchronous sequence of elements of type T. See the Stream documentation and the AsyncStream API documentation | |
A non-empty and possibly infinite asynchronous sequence of elements of type T. See the Stream documentation and the AsyncStream API documentation | |
An interface that extends the standard | |
An iterator that extends the default | |
A possibly infinite sequence of elements of type T. See the Stream documentation and the Stream API documentation | |
A non-empty and possibly infinite sequence of elements of type T. See the Stream documentation and the Stream API documentation | |
An object that can create a Stream of elements of type | |
An object that can create a non-empty Stream of elements of type |
Type Aliases
An AsyncReducer that produces instances of | |
An AsyncReducer that produces instances | |
Any object that is Iterable, a Stream, or can produce a Stream. | |
Any object that is a non-empty Stream, can produce a non-empty Stream, or is a non-empty array. | |
A Reducer that produces instances of | |
A Reducer that produces instances of |