through-json

Through stream that parses each write as a JSON message.

npm install through-json

Usage

var parse = require('through-json');

// parse returns a streams2 through stream

var p = parse();

p.on('data', function(data) {
	console.log(data.message);
});

p.on('end', function() {
	console.log('no more messages');
});

// each write must be a complete JSON message

p.write('{"message":"test"}');
p.write('{"message":"another test"}');
p.end();

Running the above program produces the following output

test
another test
no more messages

License

MIT