@tdio/stream
Stream utils with some light warppers (based on builtin "stream")
Install
yarn add @tdio/streamUsage
import { through } from '@tdio/stream'
process.stdin
.pipe(through(function(chunk, enc, cb) {
console.log('--->', chunk)
cb(null, '[' + Date.now() + '] ' + chunk)
}))
.pipe(process.stdout)