Helper functions for streams in node js.
map
import { map } from 'stream-function'
somestream.pipe(map(somefunction))
filter
import { filter } from 'stream-function'
somestream.pipe(filter(somefunction))
flatten
import { flatten } from 'stream-function'
somestream.pipe(flatten())
buffer
import { buffer } from 'stream-function'
somestream.pipe(buffer(buffersize))
promiseMap
import { map } from 'stream-function'
somestream.pipe(promiseMap(somepromisefunction))