A light framework for functional AsyncIterable processing

Pluggable text→vector embedding provider — generic EmbeddingProvider interface, config-driven model resolution, async batch-first API (AsyncIterable). Default: fastembed (local ONNX, >=3 model dims proven). Loud-fail: createEmbeddingProvider() throws Reso

Create an AsyncIterable from an evented stream

Get the first fulfilled promise that satisfies the provided testing function

Async Iterables Combinators

Writer tree architecture — TSX as template language, StreamSource AsyncIterable, core <seq>/<text>/<stream>/<htmlele>, stdlib function components

Converts a stream to an `AsyncIterable<T>`

wrapper that creates an AsyncIterable of events coming from an EventEmitter

Zero-dependency primitives for bridging AsyncIterable with Node.js and Web streams, with backpressure and abort support.

Multipart and Tar utilities for the Web Streams API

Functional Iterable and AsyncIterable

Fastify plugin for sending server side events.

API for working with Iterable and AsyncIterable objects and some useful container types

Type-safe transformer functions for `Iterable` and `AsyncIterable` (`map`, `flatten`, `reduce`, etc.).

Web API compatible Blob implementation

Zero-dependency TypeScript stream orchestration for LLM pipelines — race, fallback, merge, and tee over any AsyncIterable or ReadableStream, generic over T.

Notifier allows services to update clients about state changes using a stream of promises

[DepUp] Convert a string/promise/array/iterable/asynciterable/buffer/typedarray/arraybuffer/object into a stream

Async iterable class

Web API compatible Blob implementation