composable passthrough stream for guessing data type based on the first Buffer in a stream
detect content-types via streams
Create a stream that emits events from multiple other streams
minimal implementation of a PassThrough stream
A stream that emits multiple other streams one after another.
Toggle the CLI cursor
a JSON logging library for node.js services
Get and validate the raw body of a readable stream.
Buffers events from a stream until you are ready to handle them.
writable stream that concatenates strings or binary data and calls a callback with the result
Determine if an object is a Stream
Concatenate a readable stream's data into a single array
Get an event when you're being sent data or asked for it.
a JSON logging library for node.js services
Convert a string/promise/array/iterable/asynciterable/buffer/typedarray/arraybuffer/object into a stream
Node.js Streams, a user-land copy of the stream library from Node.js
Merge multiple streams into a unified stream
Check if a stream has ended
[](https://npmjs.org/package/stream-combiner) [](https://travis-ci.org/dominictarr/stream-combiner)
Check if something is a Node.js stream
This is a sequel to [stream-combiner](https://npmjs.org/package/stream-combiner) for streams3.
Clone a Node.js HTTP response stream
Streaming parser + serializer for various mime-types
Get a stream as a string, Buffer, ArrayBuffer or array
Streaming CSV processor with row-by-row transforms, validations, column plucking, streaming each_hash iteration, filtering, writing, error recovery, and automatic delimiter detection.
Amazon Web Services event stream library. Decodes and encodes binary stream under `vnd.amazon.event-stream` content-type
A specification of what stream types different clients use. The hash is intended used as reference for tests.
Build and parse multipart/form-data request bodies with a clean DSL for adding text fields and file uploads, including automatic MIME type detection, IO streaming, boundary generation, and content type headers.
Streaming packet header types to the command-line.
A basic libary for json rpc that allow you to easly create one for your streamtype. It includes tcp json rpc on socket connections.
A robust, type-safe Ruby SDK for seamless integration with the FastPix API platform for media uploads, live streaming, playlists, analytics, and signing keys.
:: wmainfo-rb :: Author: Darren Kirby mailto:bulliver@badcomputer.org License: Ruby = Quick API docs = == Initializing == require 'wmainfo' foo = WmaInfo.new("someSong.wma") ... or ... foo = WmaInfo.new("someVideo.wmv", :encoding=>"UTF-16LE") (default encoding is ASCII) ... or ... foo = WmaInfo.new("someVideo.wmv", :debug=>1) == Public attributes == @drm :: 'true' if DRM present else 'false' @tags :: dict of strings (id3 like data) @info :: dict of variable types (non-id3 like data) @ext_info :: dict of variable types (non-id3 like data) from ASF_Extended_Content_Description_Object @headerObject :: dict of arrays (name, GUID, size and offset of ASF objects) @stream :: dict of variable types (stream properties data) == Public methods == print_objects :: pretty-print header objects hasdrm? :: returns True if file has DRM hastag?('str') :: returns True if @tags['str'] exists print_tags :: pretty-print @tags dict hasinfo?('str') :: returns True if @info['str'] exists print_info :: pretty-print @info dict print_stream :: pretty-print @stream dict For more/different documentation see http://badcomputer.org/unix/code/wmainfo/ == Thanks/Contributors == Ilmari Heikkinen sent in a fix for uninitialized '@ext_info'. Guillaume Pierronnet sent in a patch which improves character encoding handling.
Hot Potato is an open source real-time processing framework written in Ruby. Originally designed to process the Twitter firehose at 3,000+ tweets per second, it has been extended to support any type of streaming data as input or output to the framework. The framework excels with applications such as, social media analysis, log processing, fraud prevention, spam detection, instant messaging, and many others that include the processing of streaming data.
A Ruby port of Google's A2UI (Agent-to-User Interface) for Rails. Uses DSPy.rb to generate typed UI descriptions from natural language, rendered as ViewComponents via Turbo Streams.
Ruby wrapper over T-Bank Invest gRPC API (invest-contracts). Typed client for accounts, instruments, orders, and market data streams.
A complete flash message system for Rails 8 with Stimulus, Turbo Streams support, and Tailwind CSS styling. Features auto-dismiss, pause on hover, multiple message types, and clean helper methods.
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.