await-map-stream - Lightweight stream mapper
Common usage:
const awaitStream = require('await-map-stream');
let doubler = awaitStream(data => Promise.resolve(data * 2));
stream.pipe(doubler);
let mapper = awaitStream(async data => await mongodb.findOne(data.id));
request(url).pipe(JSONStream.parse('results.*')).pipe(mapper);
npm install await-map-stream
maktwin (Maksym Panchokha)
Please report any bugs or feature requests to Github https://github.com/maktwin/await-map-stream