Inspired by Dominic Tarr's through in that it's so much easier to make a stream out of a function than it is to set up the prototype chain properly: through(function (chunk) { ... }).Note: As 2.x.x this module starts using Streams3 instead of Stream2. To continue using a Streams2 version use npm install through2@0 to fetch the latest version of 0.x.x. More information about Streams2 vs Streams3 and recommendations see the article Why I don't use Node's core 'stream' module.
stream streams2 through transformPerform a map on a stream of objects.Let's say you are consuming an array of objects in the form of a stream. This node module lets you return a named property for each object in the stream, in reality performing a map on the entire array.
object stream streams streams2 map array property attributeAn ES6/ES2015 Tagged String Literal tag that can interpolate Node.JS streams, strings and Promises that return either (or arrays of any of those) and produces a Node.JS stream. This allows you to join several Streams together with bits in between without having to buffer anything.Written by Thomas Parslow (almostobsolete.net and tomparslow.co.uk) for IORad (iorad.com) and released with their kind permission.
streams stream streaming streams2 template taggedliteral literal string es6 templatingA simple way to create a Node.JS Transform stream which processes in parallel. You can limit the concurrency (default is 16) and order is not preserved (so chunks/objects can end up in a different order to the order they started in if the transform functions take different amounts of time).Built using through2 and has the same API with the addition of a maxConcurrency option.
through2 streams streams2 through transform concurrency paralleltar-stream is a streaming tar parser and generator and nothing else. It is streams2 and operates purely using streams which means you can easily extract/parse tarballs without ever hitting the file system.Note that you still need to gunzip your data if you have a .tar.gz. We recommend using gunzip-maybe in conjunction with this.
tar tarball parse parser generate generator stream stream2 streams streams2 streaming pack extract modifyStreamable content addressable blob object store that is streams2 and implements the blob store interface on top of the fs module.Conforms to the abstract-blob-store API and passes it's test suite.
blob object store content addressable streams2Turn a writeable and readable stream into a single streams2 duplex stream.If you call setReadable or setWritable multiple times it will unregister the previous readable/writable stream. To disable the readable or writable part call setReadable or setWritable with null.
duplex streams2 streams stream writable readable asynca through stream that destroys itself if an overall size limit for the combined stream throughput is exceeded. useful for e.g. limiting HTTP upload size
stream streams2 through2Will parse an input character stream and pass on an array for each line of CSV data.The only main "feature" not currently supported is newlines within quoted strings; newlines are treated strictly as row separators.
stream streams2 csvThis module provides a wrap function based on Readable().wrap() from node core but as a standalone module.Use this module if you don't want to wait for a patch in node core to land that fixes falsey objectMode values in wrapped readable streams.
streams1 streams2 readable-stream streams wrapperA collection of Node.js transform stream utilities for simple data manipulation.Install with npm install sculpt --save.
stream streams2 transform objectmodeThe above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
stream sink streams2 test debugTakes a Writable stream and a Readable stream and makes them appear as a Duplex stream. Heavily inspired by duplexer but using Stream2 with a bundled readable-stream. It is assumed that the two streams are connected to each other in some way.
duplexer streams streams2 duplex readable writableProvide a the digest algorithm, optional input encoding, digest encoding, and a listener function when you construct the stream. The listener will be called with the resultant digest and length of the stream just prior to end being emitted. Since this uses the node.js crypto package, refer to http://nodejs.org/api/crypto.html for the specific options available.
stream streams2 digest crypto sha1 md5 hash length filter through pipepass-stream is a pass-through stream which allows transform fns for easily filtering or adapting the data that flows through the stream. To add transform/filter functionality you may provide a writeFn and/or endFn which allows you to tap into the write and end processing.
stream streams2 filter transform through pipe pause drain bufferredis-rstream is a node.js redis read stream which streams binary or utf8 data in chunks from a redis key using an existing redis client. (streams2) Tested with mranney/node_redis client. You will also need the redis client (npm install redis) or other compatible library. You an also optionally install hiredis along with redis for additional performance.
stream streams2 read redis binaryYou will also need the redis client (npm install redis) or other compatible library. You an also optionally install hiredis along with redis for additional performance. Construct a write stream instance by passing in client and key to save stream to. Pipe to this instance and when end is emitted, the stream has been saved to redis.
stream streams2 write redis binary
We have large collection of open source products. Follow the tags from
Tag Cloud >>
Open source products are scattered around the web. Please provide information
about the open source projects you own / you use.
Add Projects.