陈鹏铭 93064e9f91 首次提交 преди 11 месеца
..
LICENSE 93064e9f91 首次提交 преди 11 месеца
README.md 93064e9f91 首次提交 преди 11 месеца
index.js 93064e9f91 首次提交 преди 11 месеца
package.json 93064e9f91 首次提交 преди 11 месеца

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