| import { EmptyError } from './util/EmptyError'; |
| import { SafeSubscriber } from './Subscriber'; |
| export function firstValueFrom(source, config) { |
| var hasConfig = typeof config === 'object'; |
| return new Promise(function (resolve, reject) { |
| var subscriber = new SafeSubscriber({ |
| next: function (value) { |
| resolve(value); |
| subscriber.unsubscribe(); |
| }, |
| error: reject, |
| complete: function () { |
| if (hasConfig) { |
| resolve(config.defaultValue); |
| } |
| else { |
| reject(new EmptyError()); |
| } |
| }, |
| }); |
| source.subscribe(subscriber); |
| }); |
| } |
| //# sourceMappingURL=firstValueFrom.js.map |