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

A light framework for functional AsyncIterable processing

Get the first fulfilled promise that satisfies the provided testing function

Create an AsyncIterable from an evented stream

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

Async Iterables Combinators

Multipart and Tar utilities for the Web Streams API

Fastify plugin for sending server side events.

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

Converts a stream to an `AsyncIterable<T>`

Functional Iterable and AsyncIterable

wrapper that creates an AsyncIterable of events coming from an EventEmitter

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.

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

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

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

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

Web API compatible Blob implementation

Create a @most/core stream from an AsyncIterable