๐ Callbag operator that drops consecutive duplicate values
๐ Callbag operator that emits the previous and current values as an array.
make it easier to work with streams
Chunking for CAR files. Split a single CAR into multiple CARs.
Utility functions for Web Streams
Join strategies for Iterables, Maps, and Arrays.
Indexes for CARs.
Flexible Byte Layout is an advanced layout for representing binary data.
A light framework for functional AsyncIterable processing
Utility library to operate with JavaScript Streams API
Reactive stream library. Streams are lazy, pull-on-subscribe, and async-by-default.
A generic sink stream for Promistreams that can cover most usecases. It automatically drives the pipeline above it once it is read from once, in its default configuration.
A node.js lib to process files/data like spark rdd.
Convert to & from web streams to other data structures
Have single-channel frequency sample data? Want single-channel audio PCM data?
A stream for debugging purposes, that logs everything that goes through it
TypeScript implementation of the SuperMinHash algorithm for Jaccard similarity estimation
A powerful, type-safe, and highly extensible iterator library for TypeScript/JavaScript, supporting both synchronous and asynchronous processing with dedicated sequential and parallel modes.
General-purpose forking stream
Linq implementation for JS
Zero-dependency TypeScript Go-style async channels: buffered/unbuffered Channel , select(), close(), for-await iteration, AbortSignal cancellation. Port of Go channels / Python asyncio.Queue / C# Channel .
minimal pull streams in rescript
Functional async iterators for TypeScript, built on fp-ts.
Experimental code: If we had tool functions for Iterables and AsyncIterables in JavaScriptโs standard library โ what would they look like?
LazyStream.TS provides an easy way to work with collections in FP-like and SQL-like styles.