a simple Readable stream to consume JSON published over redis pub/sub
Vscode-free host library for talking to a `lace engine` process from Node.js. Provides the gRPC-JS transport, server lifecycle, handshake parser, RPC error classifier, and the Subscribe stream handler.
Node.js Streams, a user-land copy of the stream library from Node.js
Check if something is a Node.js stream
Get a stream as a string, Buffer, ArrayBuffer or array
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.
Toggle the CLI cursor
destroy a stream if possible
The official Next Generation JavaScript SDK for SkyWay
Call a callback when a readable/writable/duplex stream has completed or failed.
An Observable push stream
The official Next Generation JavaScript SDK for SkyWay
Get and validate the raw body of a readable stream.
A streaming way to send data to a Node.js Worker Thread
A stream that emits multiple other streams one after another.
Library for resuming and following streams in distributed systems
Streaming data for JavaScript
Merge multiple streams into a unified stream
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
An iteration of the Node.js core streams with a series of improvements
Returns the next buffer/object in a stream's readable queue
Streaming HTML parser with scripting support.
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.
minimal implementation of a PassThrough stream
Subscribe (tail) Riemann event streams from the console
Thread-safe in-memory event store for CQRS patterns. Supports named streams, event appending, stream reading, subscriber notifications, and state projections.
This gem implements basic logic for nats listeners. It's created for modular purpose.
Nats streaming client and subscriber implementation.
Nagare is a wrapper around Redis Streams that enables event-driven architectures and pub/sub messaging withdurable subscribers
Weeter subscribes to a set of twitter users or search terms using Twitter's streaming API, and notifies your app with each new tweet.
Subscribes to Solana WebSocket RPC for account changes and broadcasts updates via ActionCable/Turbo Streams. Includes Idiomorph auto-refresh Stimulus controller.
Build reactive, real-time UI components that automatically re-render server-side when subscribed models change. Uses ViewComponent, Turbo Streams, and ActionCable to keep your UI in sync without writing custom JavaScript.
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.