123456789101112131415161718192021222324252627 |
- import { EmptyError } from './util/EmptyError';
- export function lastValueFrom(source, config) {
- const hasConfig = typeof config === 'object';
- return new Promise((resolve, reject) => {
- let _hasValue = false;
- let _value;
- source.subscribe({
- next: (value) => {
- _value = value;
- _hasValue = true;
- },
- error: reject,
- complete: () => {
- if (_hasValue) {
- resolve(_value);
- }
- else if (hasConfig) {
- resolve(config.defaultValue);
- }
- else {
- reject(new EmptyError());
- }
- },
- });
- });
- }
- //# sourceMappingURL=lastValueFrom.js.map
|