Skip to main content
Deno 2 is finally here 🎉️
Learn more
Module

x/rimbu/stream/async/async-transformer.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@1.0.0/stream/async/async-transformer.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.

Type Aliases

An AsyncReducer that produces instances of AsyncStreamSource.

An AsyncReducer that produces instances AsyncStreamSource.NonEmpty.