diff options
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/firstValueFrom.js')
| -rw-r--r-- | node_modules/rxjs/dist/esm/internal/firstValueFrom.js | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/firstValueFrom.js b/node_modules/rxjs/dist/esm/internal/firstValueFrom.js new file mode 100644 index 0000000..26c8b9f --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/firstValueFrom.js @@ -0,0 +1,24 @@ +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
\ No newline at end of file |
