simple push-based streams
An Observable push stream
wrap a push-stream into a pull-stream, for source, sink, and duplex.
An Observable push stream
Pushstream.js from nginx-push-stream-module
Single-consumer push-pull async stream with enqueue/done/error semantics (inspired by claude-code Stream<T>)
Optional Vala/GObject bridge providing nghttp2 primitives unreachable through libsoup's high-level GIR API: HPACK header-block encoding (for PUSH_PROMISE / DATA frames), server-side push stream-ID allocation, and a thin nghttp2_session wrapper for future
Node.js Streams, a user-land copy of the stream library from Node.js
node.js through stream that emits a unique stream of objects based on criteria
Check if something is a Node.js stream
Get a stream as a string, Buffer, ArrayBuffer or array
Modern version of `duplexer2`
tar-stream is a streaming tar parser and generator and nothing else. It operates purely using streams which means you can easily extract/parse tarballs without ever hitting the file system.
Call a callback when a readable/writable/duplex stream has completed or failed.
Toggle the CLI cursor
destroy a stream if possible
Push an array of items into an array, while being robust against prototype modification
Get and validate the raw body of a readable stream.
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
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.
Streaming data for JavaScript
A streaming way to send data to a Node.js Worker Thread
A stream that emits multiple other streams one after another.
minimal implementation of a PassThrough stream
A ruby client for publishing messages to your http pub/sub service provided by the nginx-push-stream-module
This gem is a logstash plugin required to be installed on top of the Logstash core pipeline using $LS_HOME/bin/plugin install gemname. This gem is not a stand-alone program
Linefeed turns a push-style byte stream, of any chunk size, into individually yielded lines.
ConduitSSE provides a flexible callback-based architecture for processing real-time server push data with full control over every stage of the parsing pipeline. Perfect for streaming AI responses, real-time analytics, and live updates.
A comprehensive test framework for validating A2A protocol server implementations. Includes tests for REST and gRPC bindings covering agent discovery, messaging, streaming, task management, push notifications, error handling, and more.
modal_stack adds a navigation stack on top of Hotwire: push N modals/drawers/bottom sheets, deep-link the top of the stack via native Rails URLs, get full browser history (back/forward) support, and drive everything from imperative Turbo Stream actions (modal_push, modal_pop, modal_replace).
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.