17 lines
644 B
17 lines
644 B
import { Observable } from '../Observable'; |
|
import { Subscription } from '../Subscription'; |
|
export function schedulePromise(input, scheduler) { |
|
return new Observable(subscriber => { |
|
const sub = new Subscription(); |
|
sub.add(scheduler.schedule(() => input.then(value => { |
|
sub.add(scheduler.schedule(() => { |
|
subscriber.next(value); |
|
sub.add(scheduler.schedule(() => subscriber.complete())); |
|
})); |
|
}, err => { |
|
sub.add(scheduler.schedule(() => subscriber.error(err))); |
|
}))); |
|
return sub; |
|
}); |
|
} |
|
//# sourceMappingURL=schedulePromise.js.map
|