streamss

A stream2 collection.

A stream2 collection for common stream use-cases.

• Split, SplitLine : (Transform) Splits up a stream into pieces
• JsonArray : (Transform) Json parse a line into an object stream and/or stringify back into a single line.
• ReadArray : (Readable) Read from an Array and push it as stream.
• ReadBuffer : (Readable) Read from an Buffer/ String and push it as stream
• WriteArray : (Writable) Collects stream chunks into Array

Works with node v0.8.x and greater. For node v0.8.x the user-land copy readable-stream is used. For all other node versions greater v0.8.x the built-in stream module is used.

Table of Contents

• Interface
  • Split([options])
  • SplitLine([options])
  • JsonArray([options])
  • JsonArray.parse([options])
  • JsonArray.stringify([options])
  • ReadArray([options], array)
  • ReadArray.obj([options], array)
  • ReadBuffer([options], buffer)
  • WriteArray([options], callback)
  • WriteArray.obj([options], callback)
  • Through
• Contribution and License Agreement
• License

Interface

Split([options])

Split a stream using a regexp or string based matcher

Parameters:

• {Object} [options] - Stream Options {encoding, highWaterMark, decodeStrings, ...}
• {RegExp | String} options.matcher - RegExp or String use for splitting up the stream. Default=/(\r?\n)/

Return:

{Transform} A transform stream

Example

const { Split, Through } = require('streamss')

require('fs').createReadStream(__dirname + '/../test/test.txt')
  .pipe(Split({ matcher: ' are ', encoding: 'utf8' }))
  .pipe(Through(
    { decodeStrings: false },
    function(string) {
      this.push('>>>' + string + '<<<\n')
    }
  ))
  .pipe(process.stdout)

Run in terminal:

node examples/split.js

SplitLine([options])

Split a stream by a single char

Works on buffers - should therefore be faster than Split.

Parameters:

• {Object} [options] - Stream Options {encoding, highWaterMark, ...}
• {Boolean} options.chomp - Do not emit the matching char. Default=false
• {String} options.matcher - String use for splitting up the stream. Default=0x0a

Return:

{Transform} A transform stream

Example

const { Split, Through } = require('streamss')

require('fs').createReadStream(__dirname + '/../test/test.txt')
  .pipe(SplitLine({ matcher: 'i', chomp: true, encoding: 'utf8' }))
  .pipe(Through(
    { decodeStrings: false },
    function(string) {
      this.push('>>>' + string + '<<<\n')
    }
  ))
  .pipe(process.stdout)

Run in terminal:

node examples/splitline.js

JsonArray([options])

JSON.parse a line and push as object down the pipe.

If stringify: true is set, a received object is stringified with JSON.stringify The output of the stream will be a valid JSON array.

NOTE: Requires that the stream is split beforehand using Split or SplitLine.

Parameters:

• {Object} [options] - Options
• {Boolean} options.stringify - Transforms an object into a string using JSON.stringify. Default=false.
• {Boolean} options.error - Emit parsing errors as Error objects. Default=false.
• {Boolean} options.validJson - Write out a valid json file, which can be parsed as a whole. Default=true.

Return:

{Transform} A transform stream

JsonArray.parse([options])

Shortcut for parse

Parameters:

• {Object} [options] - Options
• {Boolean} options.error - Emit parsing errors as Error objects. Default=false. Return:

{Transform} A transform stream

JsonArray.stringify([options])

Shortcut for stringify

Parameters:

• {Object} [options] - Options
• {Boolean} options.validJson - Write out a valid json file, which can be parsed as a whole. Default=true.

Return:

{Transform} A transform stream

Example

const { JsonArray, SplitLine } = require('streamss')

require('fs').createReadStream(__dirname + '/../test/test.json')
  .pipe(SplitLine())
  .pipe(JsonArray.parse())
  .pipe(JsonArray.stringify())
  .pipe(process.stdout)

Run in terminal:

node examples/jsonarray.js

ReadArray([options], array)

Read from an Array and push into stream.

Takes care on pausing to push to the stream if pipe is saturated.

Parameters:

• {Object} [options] - Stream Options {encoding, highWaterMark, decodeStrings, ...}
• {Array} array - array to push down as stream (If array is an array of objects set objectMode:true or use ReadArray.obj)

Return:

{Readable} A readable stream

ReadArray.obj([options], array)

Shortcut for objectMode

Parameters:

• {Object} [options] - Stream Options {encoding, highWaterMark, decodeStrings, ...}
• {Array} array - array to push down as stream

Return:

{Readable} A readable stream

ReadBuffer([options], buffer)

Read from an Buffer/ String and push into stream.

Takes care on pausing to push to the stream if pipe is saturated. Pushes only size bytes if highWaterMark is set.

Parameters:

• {Object} [options] - Stream Options {encoding, highWaterMark, ...}
• {Buffer | String} buffer - buffer to push down as stream

Return:

{Readable} A readable stream

Example

Pushes a string per 7 bytes as stream into an array.

const { ReadArray, WriteArray } = require('streamss')

const str = "line 1\nline 2\nline 3\nline 4";

ReadBuffer(
  {highWaterMark: 7, encoding: 'utf8'},
  str
).pipe(WriteArray(
  { decodeStrings: false },
  function(err, arr){
    console.log(arr)
    //> [ 'line 1\n', 'line 2\n', 'line 3\n', 'line 4' ]
  })
)

WriteArray([options], callback)

Write stream into an Array

Parameters:

• {Object} [options] - Stream Options {encoding, highWaterMark, decodeStrings, objectMode, ...}
• {Function} callback - callback function called on finish or error event. Form is function(err, array).

Return:

{Writable} A writable stream

WriteArray.obj([options], callback)

Shortcut for ObjectMode

Parameters:

• {Object} [options] - Stream Options {encoding, highWaterMark, decodeStrings, ...}
• {Function} callback - callback function called on finish or error event. Form is function(err, array).

Return:

{Writable} A writable stream

Example

const { ReadArray, WriteArray, Through } = require('streamss')

const array = [ '1', '2', '3', '4', '5', '6', '7', '8', '9', '10' ]
let cnt = 0

ReadArray(
  { encoding: 'utf8'},
  array
)
.pipe(Through(
  { encoding: 'utf8'},
  function(str) {
    if (cnt++ % 2) {
      this.push(str)
    }
  }
))
.pipe(WriteArray(
  { decodeStrings: false },
  function(err, arr){
    console.log(arr)
    //> [ '2', '4', '6', '8', '10' ]
  })
)

Run in terminal:

node examples/readwritearray.js

Through

See streamss-through.

Contribution and License Agreement

If you contribute code to this project, you are implicitly allowing your code to be distributed under the MIT license. You are also implicitly verifying that all code is your original work.

• npm test - Run tests
• npm run lint - Linting the source
• npm run cover - Run istanbul code coverage
• npm run doc - Generate documentation from source

License

Copyright (c) 2014, Commenthol. (MIT License)

See LICENSE for more info.