async.js

function async(makeGenerator) {
  // Return a function that constructs an Observable.
  return function(...args) {
    return Observable.create(observer => {
      // This function won't be called until the observable is subscribed.
      const generator = makeGenerator.apply(this, args)
      return new GeneratorSubscriber(observer, generator)
    })
  }
}