Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
A through2 wrapper to for simple stream.PassThrough spies.
JavaScript
Branch: master

2.0.0

latest commit 9779ae85c7
@brycebaril authored
Failed to load latest commit information.
test Add obj, objCtor
.gitignore update deps, swap concat-stream for terminus due to breaking changes
LICENSE Initial version
README.md Add obj, objCtor
index.js Add obj, objCtor
package.json 2.0.0

README.md

through2-spy

NPM

This is a super thin wrapper around through2 for creating simple stream.PassThrough spies.

Saves you a tiny bit of boilerplate compared to through2 for writing stream spies.

Note you will NOT be able to do anything but spy and abort the stream pipeline. To do any filtering or transformations you should consider through2 through2-filter or through2-map.

Pass a function to run as each chunk goes through your stream pipeline. Return an Error to abort the pipeline.

var spy = require("through2-spy")

var count = 0
var countChunks = spy(function (chunk) {
  count++
})

// vs. with through2:
var countChunks = through2(function (chunk, encoding, callback) {
  count++
  this.push(chunk)
  return callback()
})

// Then use your spy:
source.pipe(countChunks).pipe(sink)

// Additionally accepts `wantStrings` argument to conver buffers into strings
var nsaregex = /(open source)|(foss)|(node\.js)/i
var prizm = spy({wantStrings: true}, function (str) {
  var wiretap = str.match(nsaregex)
  if (wiretap) this.emit("OMGTERRIST", wiretap[0], str)
})

prizm.on("OMGTERRIST", sendDrone(/* ... */))

internet.pipe(prizm).pipe(internet)

// Return an Error to abort the pipeline
var Meter = spy.ctor({maxBytes: 1024, bytes: 0}, function (chunk) {
  this.options.bytes += chunk.length
  if (this.options.bytes >= this.options.maxBytes) return new Error("Over 1024 byte limit!")
})

var meter = new Meter()

API

require("through2-spy")([options], fn)

Create a through2-spy instance that will call fn(chunk) and then silently pass through data downstream.

require("through2-spy").ctor([options], fn)

Create a through2-spy Type that can be instantiated via new Type() or Type() to create reusable spies.

require("through2-spy").obj([options], fn)

Create a through2-spy that defaults to objectMode = true.

require("through2-spy").objCtor([options], fn)

Create a through2-spy Type that defaults to objectMode = true.

Options

  • wantStrings: Automatically call chunk.toString() for the super lazy.
  • all other through2 options

LICENSE

MIT

Something went wrong with that request. Please try again.