diff options
Diffstat (limited to 'node_modules/rxjs/dist/cjs/internal/lastValueFrom.js')
| -rw-r--r-- | node_modules/rxjs/dist/cjs/internal/lastValueFrom.js | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/cjs/internal/lastValueFrom.js b/node_modules/rxjs/dist/cjs/internal/lastValueFrom.js new file mode 100644 index 0000000..c29d0b3 --- /dev/null +++ b/node_modules/rxjs/dist/cjs/internal/lastValueFrom.js @@ -0,0 +1,31 @@ +"use strict"; +Object.defineProperty(exports, "__esModule", { value: true }); +exports.lastValueFrom = void 0; +var EmptyError_1 = require("./util/EmptyError"); +function lastValueFrom(source, config) { + var hasConfig = typeof config === 'object'; + return new Promise(function (resolve, reject) { + var _hasValue = false; + var _value; + source.subscribe({ + next: function (value) { + _value = value; + _hasValue = true; + }, + error: reject, + complete: function () { + if (_hasValue) { + resolve(_value); + } + else if (hasConfig) { + resolve(config.defaultValue); + } + else { + reject(new EmptyError_1.EmptyError()); + } + }, + }); + }); +} +exports.lastValueFrom = lastValueFrom; +//# sourceMappingURL=lastValueFrom.js.map
\ No newline at end of file |