// In your module
module.exports = tx
var filter = require("through2-filter")
var map = require("through2-map")
var splice = require("stream-splice")
 
function tx() {
  var noBs = filter(function (chunk) { return /[^bB]/.exec(chunk) })
  var uc = map(function (chunk) { return chunk.toString().toUpperCase() })
  var zz = map(function (chunk) { return chunk.toString() + "z" })
 
  return splice(noBs, uc, zz)
}
 
// Using your module:
var tx = require("my-module")
 
source.pipe(tx()).pipe(/* ... */)
 
// That is equivalent to:
source.pipe(noBs)
  .pipe(uc)
  .pipe(zz)
  .pipe(/* ... */)
 
// A less contrived example:
// catLines is equivalent to fs.createReadStream except stream chunks
// will be the lines of the file
module.exports = catLines
 
var fs = require("fs")
var split = require("split")
var map = require("through2-map")
var splice = require("stream-splice")
 
function catLines(filename, options) {
  var rs = fs.createReadStream(filename, options)
  var reAddNewline = map(function (chunk) { return chunk.toString() + "\n" })
  return splice(rs, split(), reAddNewline)
}
 
 

source.pipe(splice(a, b, c)).pipe(drain)
 
// is roughly equivalent to
 
source.pipe(a)
  .pipe(b)
  .pipe(c)
  .pipe(drain)