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