History

Nuwan 23d1ece36d fixing controller tests after upgradeing to rails5		2022-02-15 16:27:07 +05:30
..
LICENSE	fixing controller tests after upgradeing to rails5	2022-02-15 16:27:07 +05:30
README.md	fixing controller tests after upgradeing to rails5	2022-02-15 16:27:07 +05:30
index.js	fixing controller tests after upgradeing to rails5	2022-02-15 16:27:07 +05:30
package.json	fixing controller tests after upgradeing to rails5	2022-02-15 16:27:07 +05:30

README.md

lead

Sink your streams.

Usage

var from = require('from2');
var through = require('through2');
var sink = require('lead');

// Might be used as a Transform or Writeable
var maybeThrough = through(function(chunk, enc, cb) {
  // processing
  cb(null, chunk);
});

from(['hello', 'world'])
  // Sink it to behave like a Writeable
  .pipe(sink(maybeThrough))

API

`sink(stream)`

Takes a stream to sink and returns the same stream. Sets up event listeners to infer if the stream is being used as a Transform or Writeable stream and sinks it on nextTick if necessary. If the stream is being used as a Transform stream but becomes unpiped, it will be sunk. Respects pipe, on('data') and on('readable') handlers.

License

MIT