17 lines
336 B
JavaScript
17 lines
336 B
JavaScript
|
#!/usr/bin/env node
|
||
|
|
|
||
|
|
var ForkStream = require("./");
|
||
|
|
|
||
|
|
var fork = new ForkStream({
|
||
|
|
classifier: function classify(e, done) {
|
||
|
|
return done(null, e >= 5);
|
||
|
|
},
|
||
|
|
});
|
||
|
|
|
||
|
|
fork.a.on("data", console.log.bind(null, "a"));
|
||
|
|
fork.b.on("data", console.log.bind(null, "b"));
|
||
|
|
|
||
|
|
for (var i=0;i<20;++i) {
|
||
|
|
fork.write(Math.round(Math.random() * 10));
|
||
|
|
}
|