Construct the new instance.
This is the source observable that will provide values to cache.
optional additional configuration. See class for details.
Private closeFlag stating whatever each subscription should be closed after the emission. This is true unless a flush observable is provided.
Private loadNCacheThe underlying loadNCache instance.
Internal implementation detail, do not use directly. Will be made internal in v8.
Static createCreates a new Observable by calling the Observable constructor
Observable
create
a new observable
Use new Observable() instead. Will be removed in v8.
Rest ...args: any[]Private emitUsed as a NON-CANCELLABLE means of subscribing to an observable, for use with
APIs that expect promises, like async/await. You cannot unsubscribe from this.
WARNING: Only use this with observables you know will complete. If the source observable does not complete, you will end up with a promise that is hung up, and potentially all of the state of an async function hanging out in memory. To avoid this situation, look into adding something like timeout, take, takeWhile, or takeUntil amongst others.
import { interval, take } from 'rxjs';
const source$ = interval(1000).pipe(take(4));
async function getTotal() {
let total = 0;
await source$.forEach(value => {
total += value;
console.log('observable -> ' + value);
});
return total;
}
getTotal().then(
total => console.log('Total: ' + total)
);
// Expected:
// 'observable -> 0'
// 'observable -> 1'
// 'observable -> 2'
// 'observable -> 3'
// 'Total: 6'
a promise that either resolves on observable completion or rejects with the handled error
a handler for each value emitted by the observable
a promise that either resolves on observable completion or rejects with the handled error
Passing a Promise constructor will no longer be available in upcoming versions of RxJS. This is because it adds weight to the library, for very little benefit. If you need this functionality, it is recommended that you either polyfill Promise, or you create an adapter to convert the returned native promise to whatever promise implementation you wanted. Will be removed in v8.
a handler for each value emitted by the observable
a constructor function used to instantiate the Promise
Creates a new Observable, with this Observable instance as the source, and the passed operator defined as the new observable's operator.
lift
a new observable with the Operator applied
Internal implementation detail, do not use directly. Will be made internal in v8.
If you have implemented an operator using lift, it is recommended that you create an
operator by simply returning new Observable() directly. See "Creating new operators from
scratch" section here: https://rxjs.dev/guide/operators
Optional operator: Operator<T, R>the operator defining the operation to take on the observable
Rest ...operations: OperatorFunction<any, any>[]Optional observer: Partial<Observer<T>>Instead of passing separate callback arguments, use an observer argument. Signatures taking separate callback arguments will be removed in v8. Details: https://rxjs.dev/deprecations/subscribe-arguments
Optional next: null | ((value: T) => void)Optional error: null | ((error: any) => void)Optional complete: null | (() => void)Replaced with firstValueFrom and lastValueFrom. Will be removed in v8. Details: https://rxjs.dev/deprecations/to-promise
Replaced with firstValueFrom and lastValueFrom. Will be removed in v8. Details: https://rxjs.dev/deprecations/to-promise
Replaced with firstValueFrom and lastValueFrom. Will be removed in v8. Details: https://rxjs.dev/deprecations/to-promise
Generated using TypeDoc
See README.md for class documentation.