ex2

ex2.js

async function * onlyOddPlease(input) {
  for await(const n of input) {
    // assuming that each chunk is a number
    if(n%2) yield n;
  }
}

async function * plusOne(input) {
  for await(const n of input) {
     yield n+1;
  }
}

(async function IIAFE(){
  
  for await(const n of plusOne(onlyOddPlease(misteriousStream))) {
    process.stdout.write(n);
  }
  // do other stuff
  
})();