.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/scheduled/schedulePromise.js

   1 import { Observable } from '../Observable';
   2 import { Subscription } from '../Subscription';
   3 export function schedulePromise(input, scheduler) {
   4     return new Observable(subscriber => {
   5         const sub = new Subscription();
   6         sub.add(scheduler.schedule(() => input.then(value => {
   7             sub.add(scheduler.schedule(() => {
   8                 subscriber.next(value);
   9                 sub.add(scheduler.schedule(() => subscriber.complete()));
  10             }));
  11         }, err => {
  12             sub.add(scheduler.schedule(() => subscriber.error(err)));
  13         })));
  14         return sub;
  15     });
  16 }
  17 //# sourceMappingURL=schedulePromise.js.map