1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
| import { Subscriber } from '../Subscriber';
| import { hostReportError } from './hostReportError';
|
| export const subscribeToPromise = <T>(promise: PromiseLike<T>) => (subscriber: Subscriber<T>) => {
| promise.then(
| (value) => {
| if (!subscriber.closed) {
| subscriber.next(value);
| subscriber.complete();
| }
| },
| (err: any) => subscriber.error(err)
| )
| .then(null, hostReportError);
| return subscriber;
| };
|
|