陈鹏铭 93064e9f91 首次提交 11 ay önce
..
LICENSE 93064e9f91 首次提交 11 ay önce
README.md 93064e9f91 首次提交 11 ay önce
index.js 93064e9f91 首次提交 11 ay önce
package.json 93064e9f91 首次提交 11 ay önce

README.md

lead

NPM version Downloads Build Status AppVeyor Build Status Coveralls Status Gitter chat

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