jooyunghan · December 20, 2017 16:02
diff --git a/obs-async-iterator.js b/obs-async-iterator.js
 async function consume(obs) {
  try {
    for await (const n of obs) {
      console.log(n);
    }
  } catch (e) {
    console.log('got it', e.message);
  }
  console.log('done');  
 }
 consume(Observable.interval(100).do(n => console.assert(n < 5)));
	async function consume(obs) {
	try {
	for await (const n of obs) {
	console.log(n);
	}
	} catch (e) {
	console.log('got it', e.message);
	}
	console.log('done');
	}
	consume(Observable.interval(100).do(n => console.assert(n < 5)));