agh

const agh = require('agh');

const { asyncGeneratorsFactory } = require('agh');
 
// filter function
const onlyOddPlease = function (n) {
    // assuming that 'n' is a number
    if (n % 2) return n;
}
 
// transform function
const plusOne = function (n) {
   return n + 1;
}
 
const onlyOddPleaseGen = asyncGeneratorsFactory(onlyOddPlease);
const plusOneGen = asyncGeneratorsFactory(plusOne);

const { pipe } = require('agh');
 
(async function IIAFE() {
    // pipe(inputStream, outputStream [, ...asyncGenerators]);
    // it returns the outputStream
    await pipe(inputStream, outputStream, onlyOddPleaseGen, plusOneGen);
})();