3 var ForkStream = require("./");
5 var fork = new ForkStream({
6 classifier: function classify(e, done) {
7 return done(null, e >= 5);
11 fork.a.on("data", console.log.bind(null, "a"));
12 fork.b.on("data", console.log.bind(null, "b"));
14 for (var i=0;i<20;++i) {
15 fork.write(Math.round(Math.random() * 10));