A service worker helper library that uses the Broadcast Channel API to announce when a cached response has updated
A BroadcastChannel that works in New Browsers, Old Browsers, WebWorkers, NodeJs, Deno and iframes
Listen to realtime updates to your PostgreSQL database
Node.js Streams, a user-land copy of the stream library from Node.js
Check if something is a Node.js stream
Customizable Date Picker for React
Get a stream as a string, Buffer, ArrayBuffer or array
Toggle the CLI cursor
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.
destroy a stream if possible
Call a callback when a readable/writable/duplex stream has completed or failed.
A streaming way to send data to a Node.js Worker Thread
Get and validate the raw body of a readable stream.
Returns the next buffer/object in a stream's readable queue
Streaming data for JavaScript
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
A BroadcastChannel that works in New Browsers, Old Browsers, WebWorkers
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.
Merge multiple streams into a unified stream
An iteration of the Node.js core streams with a series of improvements
A stream that emits multiple other streams one after another.
An async iterable interface for redis streams
minimal implementation of a PassThrough stream
Streaming HTML parser with scripting support.
Rails Turbo Stream broadcasting over SSE instead of WebSockets. Uses Mercure server.
Pipe data from a Ruby IO stream to a Websocket server, broadcasting to all clients.
OGN (glidernet.org) broadcasts aircraft positions as APRS/APRS-IS messages. This gem hooks into this stream of data and provides the necessary classes to parse the raw message strings into meaningful objects.
Stream State Protocol events from Active Record models with the same DX as Turbo Broadcasts — declarative streaming, automatic callbacks, and async jobs — but with offset-based resumability and persistent event logs over HTTP.
Subscribes to Solana WebSocket RPC for account changes and broadcasts updates via ActionCable/Turbo Streams. Includes Idiomorph auto-refresh Stimulus controller.
This gem helps Rails apps implement real-time like/unlike functionality on polymorphic models with Turbo Streams broadcasting.
A production-ready Action Cable subscription adapter that uses MongoDB (via Mongoid) as a durable, cross-process broadcast backend with Change Streams support
Drop-in test matchers for hotwired/turbo-rails: assert Turbo Stream responses, Turbo Frame content, ActionCable broadcasts, and Capybara page assertions. Includes RSpec matchers (have_turbo_stream, have_turbo_frame, have_broadcasted_turbo_stream_to), Minitest assertions, factory helpers, shared examples, and a Rails generator — all auto-included with zero setup.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.