poor-man's multibuffer-stream

s.js

var spigot = require("stream-spigot")
var through2 = require("through2")
var terminus = require("terminus")
var mb = require("multibuffer")

spigot(["aaaaaaaaaaa", "bbbbbbbbbbbb", "cccccccccccccccc"])
  .pipe(through2(function (chunk, encoding, callback) {
    this.push(mb.pack([chunk]))
    callback()
  }))
  .pipe(through2(function (chunk, encoding, callback) {
    this.push(mb.unpack(chunk)[0])
    callback()
  }))
  .pipe(terminus.tail(function (piece) {
    console.log("got: " + piece.toString())
  }))