1aa65372485cf3206210133e98939000aeb833fccc41ef7182f3cc50aa1b1634e2a5cfa390828edfa8b65466f56f4ddf41f9bc2df0bd797976c36d3c0f3bcd 439 B

123456789101112
  1. import { Observable } from '../Observable';
  2. import { SchedulerLike } from '../types';
  3. import { subscribeToPromise } from '../util/subscribeToPromise';
  4. import { schedulePromise } from '../scheduled/schedulePromise';
  5. export function fromPromise<T>(input: PromiseLike<T>, scheduler?: SchedulerLike) {
  6. if (!scheduler) {
  7. return new Observable<T>(subscribeToPromise(input));
  8. } else {
  9. return schedulePromise(input, scheduler);
  10. }
  11. }