Asynchronous Observable

async function* getStocksStream() {
  var reader = new AsyncFileReader(“stocks.txt”);
  try { 
    while(!reader.eof) {
      var line = await reader.readLine();
      await yield JSON.parse(line);
    }
  }
  finally {
    await reader.close();
  }
}

(async function() {
  for (let line on getStocksStream()) {
    console.log( line );
  }
}());