'on-demand': Default policy. Subscribes and re-subscribes to the original Observable once the resulting one has open subscriptions, so long as the original Observable hasn't errored or completed on previous subscriptions. Unsubscribes from the original Observable once the resulting Observable has no active subscriptions. 'keep-open': Keeps the parent subscription open even if it has no current subscriptions. 'keep-closed': Permanently unsubscribes from the original Observable once the resulting one has no active subscriptions. Subsequent subscriptions will error or complete immediately with the same signal as the original Observable if it finalized before being unsubscribed, or otherwise error.
Catches an error in the original observable
and continues the stream by asynchronously subscribing
to the Observable returned by selector.
When no selector is provided, the original observable
will be resubscribed.
Creates a new Observable that multicasts the original Observable. The original Observable will be immediately subscribed, and will continue to be even if there are no subscribers.
Returns the first synchronous value of an Observable, if any,
onEmpty if none is produced, or onError if
the Observable errors synchronously.
When onError doesn't exist, extract will
synchronously throw.
default: 2
Creates an Observable that multicasts the original Observable. The original Observable won't be subscribed until there is at least one subscriber.
default: 2
Generated using TypeDoc
Should return an observable for
catchesto continue the stream with.