push-to-pull
Convert a push-filter to a pull-filter (for simple streams)
Usage is simple. Define your filter as an (emit) -> emit
transform where emit
is (err, item)
. Then when you need an (stream) -> stream
filter, use this module to convert it.
var pushToPull = ; // Dumb filter that inputs numbers and outputs that many monkeys// Encoded as an (emit) -> emit transform filter. { return { if item === undefined return ; for var i = 1; i <= item; i++ ; }} // Same filter, but as a (stream) -> stream transform filtervar pullFilter = ;