binarize-stream

gistfile1.txt

var binarize = require('binarize.js')
var es = require('event-stream')

function createEncodeStream() {
  var stream
  return stream = es.through(function (data) {
    binarize.pack(data, function(r) {
      stream.emit('data', r.buffer)
    });    
  })
}

function createDecodeStream() {
  var stream
  return stream = es.through(function (data) {
    binarize.unpack(data, function(r) {
      stream.emit('data', r)
    })    
  })
}

exports.getStream = function(stream) {   
   return es.pipeline(createDecodeStream(), stream, createEncodeStream())
}