streams2_gamut.js

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

spigot(["a", "b", "c"])
  .pipe(through2(function (chunk, encoding, callback) {
    console.log("spied chunk " + chunk.toString())
    this.push(chunk)
    callback()
  }))
  .pipe(terminus.concat(function (chunks) {
    console.log("got: " + chunks.toString())
  }))

// spied chunk a
// spied chunk b
// spied chunk c
// got: [object Uint8Array]