❤
npm
Sign UpSign In

take-stream

0.0.0 • Public • Published

A transform stream that passes through the first n elements and discards the rest

Example

Outputs [1, 2, 3, 4, 5]:

var Take = require('stream-take'),
    five = Take(5),
    out = [];
 
five.on('data', function(d) {
    out.push(d);
});
 
five.on('end', function() {
    console.log(out);
});
 
five.write(1);
five.write(2);
five.write(3);
five.write(4);
five.write(5);
five.write(6);
five.write(7); // Returns false, signalling backpressure

Limitations

  • Currently supports only objectMode, no strings or Buffers
  • Doesn't produce backpressure immediately due to a node bug

/take-stream/

    Package Sidebar

    Install

    npm i take-stream

    Weekly Downloads

    1

    Version

    0.0.0

    License

    MIT

    Last publish

    Collaborators

    • jfirebaugh
    Try on RunKit
    Report malware