s.js

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

var count = 0
spigot(function () {
    if (count++ < 3) {
      this.push(new Uint8Array())
    }
    else {
      this.push(null)
    }
  })
  .pipe(through2(function (chunk, encoding, callback) {
    var zz = mb.pack([chunk])
    console.log(zz)
    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())
  }))