a set of helper functions design to manage Readable and Writable streams. It uses [Callbag](https://github.com/callbag/callbag) pattern under the hood.
Toggle the CLI cursor
Clone a Node.js HTTP response stream
Extensions to Node.js child_process module
Convert a string/promise/array/iterable/asynciterable/buffer/typedarray/arraybuffer/object into a stream
Encode FormData content into the multipart/form-data format
Wrapper for piping data into and out of child processes
Reactive dataflow processing.
Node.js Streams, a user-land copy of the stream library from Node.js
[](https://npmjs.org/package/stream-combiner) [](https://travis-ci.org/dominictarr/stream-combiner)
Check if something is a Node.js stream
Bytes go in, but they don't come out (when muted).
Use websockets with the node streams API. Works in browser and node, with all current WS versions
Get a stream as a string, Buffer, ArrayBuffer or array
Sets up a duplex object stream over window.postMessage
This is a sequel to [stream-combiner](https://npmjs.org/package/stream-combiner) for streams3.
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.
node.js library for reading and extraction of ZIP archives
WebSocket protocol handler with pluggable I/O
Put a little spinner on process.stderr, as unobtrusively as possible.
Call a callback when a readable/writable/duplex stream has completed or failed.
destroy a stream if possible
A stream meter that both counts the bytes piped through it, and can optionally abort on a max size. (e.g. limit a http request size)
Process zip files using streaming API
Thin wrapper around [`tokio::process`] to make it streamable
Simple crate that wraps a tokio::process into a tokio::stream
wraps tokio-pty-process in order to provide a simpler API as a single stream object
Lightweight background and stream processing for Ruby
Defines a DSL to allow stream processing from various sources for output to various sinks
This tool assists in the creation and processing of workflows.
linedump allows you to register blocks to consume live output streams, line by line.
Wrapper around Open3#popen2e with other useful options.
Performance-oriented stream processing built on Kafka and Zookeeper
Classes to process various joins in Hadoop Map/Reduce Streaming.
Fluentd Input/Output plugin to collect/process tweets with Twitter Streaming API.
An attempt at making CLI-based data processing simpler.
TopNotify use to process notification stream from TOP.
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.