upstream: [-a-b-c-d-e------------]
flydUntil(3,stream): [-.-.-.----------------]
downstream: a b c
install..
npm install flyd-until
npm install sourcevault/flyd-until#dist
simple example ..
var flydUntil = require ("flyd-until")
var send = flyd.stream()
flydUntil(3,send)
.map (function (x){
console.log(x); // a b c
})
setTimeout(function(){
send("a")
send("b")
send("c")
send("d")
send("e")
},100)Code and documentation is released under MIT Licence, see LICENSE for details.