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