filter.js

// filter := ((Value) => Boolean) => source:Stream => Stream
function filter(lambda) { return function (source) {
    return source.pipe(through(function write(chunk) {
        if (lambda(chunk)) {
            this.push(chunk)
        }
    }))
} }