through2-objectify

var srv = net.createServer(function(c) {
c.end('abc')
}).listen(1337)

net.connect(1337).pipe(objectify(function(chunk, enc, cb) {
var s = chunk.toString()
for (var i = 0; i < s.length; i++) {
this.push({ c: s[i] })
}
cb()
})).pipe(concat(function(values) {
console.dir(values)
/* Output:
[
{ c: 'a' },
{ c: 'b' },
{ c: 'c' }
]
*/

objectify([options,] transformFn [, flushFn])

Create a through2 transform stream that converts buffers (or strings) to objects.

objectify.ctor([options,] transformFn [, flushFn])

Returns a constructor function for a custom stream that converts buffers (or strings) to objects. Useful if you want to have multiple streams with the same transform/flush functions, or if you want to inherit from the stream type.

objectify.deobj([options,] transformFn [, flushFn])

Create a through2 transform stream that converts objects to buffers (or strings).

objectify.deobjCtor([options,] transformFn [, flushFn])

Returns a constructor function for a custom stream that converts objects to buffers (or strings).

$3

objectHighWaterMark

Sets the highWaterMark specifically for the object side of the stream
(i.e. Readable on objectify, Writable on deobjectify). This allows you to control highWaterMarks separately
and not buffer e.g. 16k objects when you want to buffer 16k bytes.

Defaults to 16.

$3

Called for each buffer/string/object that needs to be transformed. See streams and through2 documentation for further details.

$3

Installation

Running tests