EventSource implemented in node as a readable stream
minimal implementation of a PassThrough stream
construct pipes of streams of events
destroy a stream if possible
Pause a stream's data events
Turn a writable and readable stream into a streams2 duplex stream with support for async initialization and streams1/streams2 input
A CSS-inspired language to select, sequence, and compose DOM events.
Creates a duplex stream
A tiny (741b) utility for Server Sent Event (SSE) streaming via `fetch` and Web Streams API
EventSource implemented in node as a readable stream
Streaming, source-agnostic EventSource/Server-Sent Events parser
simplified stream construction
Use websockets with the node streams API. Works in browser and node, with all current WS versions
Open Node Streams on demand.
Big-friendly JSON. Asynchronous streaming functions for large JSON data sets.
[](https://npmjs.org/package/stream-combiner) [](https://travis-ci.org/dominictarr/stream-combiner)
An iteration of the Node.js core streams with a series of improvements
A micro-library of stream components for building custom JSON and JSONC processing pipelines with a minimal memory footprint — parse, filter, and transform JSON far larger than available memory with a SAX-inspired token API, on Node.js or Web Streams.
A node.js version of unix's `tail -f` command
Retry a request.
Get an event when you're being sent data or asked for it.
Check if something is a Node.js stream
TypeScript definitions for event-stream
This is a sequel to [stream-combiner](https://npmjs.org/package/stream-combiner) for streams3.
Unified C-extension gem for zstd, lz4, and brotli compression. One-shot, streaming, IO wrappers, dictionary support. Fiber-friendly: cooperates with Fiber::Scheduler (async, falcon) so CPU-heavy compression never blocks the event loop. Ships vendored sources — no system libraries required.
A pure-Ruby, zero-dependency implementation of the Vercel AI SDK "Data Stream Protocol" (UI Message Stream Protocol) — the Server-Sent-Events wire format that drives the AI SDK's useChat / useCompletion / useObject frontend hooks. The protocol is language-agnostic by design, but Ruby had no implementation; ai_stream lets a Rails/Rack backend stream text, reasoning, tool calls, sources, files, and custom data parts to a Vercel-AI-SDK frontend with the exact frames it expects. Provider-agnostic: it composes with ruby_llm, ruby-openai, or any token source instead of competing with them.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.