(source: Observable<T>)
| 11 | |
| 12 | /** replacement for firstValueFrom in rxjs 7. We must support rxjs v6 so we cannot use it */ |
| 13 | export function firstValueFrom<T>(source: Observable<T>): Promise<T> { |
| 14 | return new Promise<T>((resolve, reject) => { |
| 15 | source.pipe(first()).subscribe({ |
| 16 | next: (value) => resolve(value), |
| 17 | error: (err) => reject(err), |
| 18 | }); |
| 19 | }); |
| 20 | } |
searching dependent graphs…