1 /** PURE_IMPORTS_START _Observable,_Subscription PURE_IMPORTS_END */
2 import { Observable } from '../Observable';
3 import { Subscription } from '../Subscription';
4 export function schedulePromise(input, scheduler) {
5 return new Observable(function (subscriber) {
6 var sub = new Subscription();
7 sub.add(scheduler.schedule(function () {
8 return input.then(function (value) {
9 sub.add(scheduler.schedule(function () {
10 subscriber.next(value);
11 sub.add(scheduler.schedule(function () { return subscriber.complete(); }));
14 sub.add(scheduler.schedule(function () { return subscriber.error(err); }));
20 //# sourceMappingURL=schedulePromise.js.map