Skip to main content
Module

x/rimbu/stream/async/index.ts

Rimbu is a TypeScript library focused on immutable, performant, and type-safe collections and other tools.
rimbu-org/rimbu
Go to Latest
import * as rimbu from "https://deno.land/x/rimbu@0.14.0/stream/async/index.ts";

Variables

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.

Functions

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.

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

Type Aliases

An AsyncReducer that produces instances of AsyncStreamSource.

An AsyncReducer that produces instances AsyncStreamSource.NonEmpty.