nuǝɯ pǝɥsᴉꞁod mǝu
    Share your code. npm Orgs help your team discover, share, and reuse code. Create a free org »

    pipestoppublic

    pipestop

    A .pipe() for node that you can stop.

    example

    single.js

    var pipestop = require('pipestop');
    var EventEmitter = require('events').EventEmitter;
     
    var em = new EventEmitter;
    var pipe = pipestop(em);
     
    var ix = 0;
    setInterval(function () {
        em.emit('data', ix++);
    }, 500);
     
    var s = fakeStream(1);
    var stop = pipe(s);
     
    setTimeout(function () {
        stop();
    }, 3001);
     
    function fakeStream () {
        var s = new EventEmitter;
        s.writable = true;
        s.write = function (x) {
            console.log('wrote ' + x);
        };
        return s;
    }

    methods

    var pipestop = require('pipestop');

    var pipe = pipestop(stream)

    Create a new pipe function for a readable stream.

    var stop = pipe(stream)

    Pipe data from the readable stream from pipestop() to the writable stream provided here.

    stop()

    Unbind all listeners that the writable stream from pipe() bound on the writable stream from pipestop().

    license

    MIT/X11

    install

    Using npm do:

    npm install pipestop
    

    Keywords

    none

    install

    npm i pipestop

    Downloadslast 7 days

    2

    version

    0.0.0

    license

    none

    repository

    github.com

    last publish

    collaborators

    • avatar