Gunzip buffers.

gistfile1.txt

var JSONStream = require('JSONStream')
  , zlib = require('zlib');

// With compression
var inputA = JSONStream.stringify()
	, outputA = JSONStream.parse([true]);

inputA.pipe(zlib.createGzip()).pipe(zlib.createGunzip()).pipe(outputA);

outputA.on('data', function (data) {
	console.log('outputA received', data);
});

// Without compression
var inputB = JSONStream.stringify()
	, outputB = JSONStream.parse([true]);

inputB.pipe(outputB);

outputB.on('data', function (data) {
	console.log('outputB received', data);
});

// Send to each
var timer = setInterval(function () {
	inputA.write('{"foo":"bar"}');
	inputB.write('{"foo":"bar"}');
}, 25);

setTimeout(function () {
	clearInterval(timer);
	inputA.end();
}, 1000);