stream-generator.js

let sink = async function(iter) {
  for (let item of iter) {
    console.log('got', await item)
  }
}

sink(function*(){
  var i = 0
  while(true) {
    yield new Promise(done => {
      setTimeout(done, 1000, i++)
    })
  }
}())