Nonflavored Prescription Medicine

pipestop

0.0.0 • Public • Published

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

Downloadsweekly downloads

0

version

0.0.0

license

none

homepage

github.com

repository

Gitgithub

last publish

collaborators

  • avatar
Report a vulnerability