Skip to content

}}})} }}},System.Boolean)}

Qbservable.DeferAsync(IQbservableProvider, Expression>>>) method

Defined in

Type: Qbservable Namespace: System.Reactive.Linq Assembly: System.Reactive.dll

Applies to

netstandard2.0

Overloads

  • 1. public static IQbservable<TResult> DeferAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<IObservable<TResult>>>> observableFactoryAsync)
  • 2. public static IQbservable<TResult> DeferAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<IObservable<TResult>>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe)

1. Overload

public static IQbservable<TResult> DeferAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<IObservable<TResult>>>> observableFactoryAsync)

Summary: Returns an observable sequence that starts the specified cancellable asynchronous factory function whenever a new observer subscribes. The CancellationToken passed to the asynchronous factory function is tied to the returned disposable subscription, allowing best-effort cancellation.

Type parameters

NameDescription
TResultThe type of the elements in the sequence returned by the factory function, and in the resulting sequence.

Parameters

NameTypeDescription
provider[IQbservableProvider](#Query provider used to construct the [IQbservable](# data source.
observableFactoryAsyncExpression>>>Asynchronous factory function to start for each observer that subscribes to the resulting sequence.

Returns: IQbservable -- An observable sequence whose observers trigger the given asynchronous observable factory function to be started.

Remarks

When a subscription to the resulting sequence is disposed, the CancellationToken that was fed to the asynchronous observable factory function will be signaled.

Exceptions

TypeCondition
System.ArgumentNullExceptionobservableFactoryAsync is null.

2. Overload

public static IQbservable<TResult> DeferAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<IObservable<TResult>>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe)

Summary: Returns an observable sequence that starts the specified cancellable asynchronous factory function whenever a new observer subscribes. The CancellationToken passed to the asynchronous factory function is tied to the returned disposable subscription, allowing best-effort cancellation.

Type parameters

NameDescription
TResultThe type of the elements in the sequence returned by the factory function, and in the resulting sequence.

Parameters

NameTypeDescription
provider[IQbservableProvider](#Query provider used to construct the [IQbservable](# data source.
observableFactoryAsyncExpression>>>Asynchronous factory function to start for each observer that subscribes to the resulting sequence.
ignoreExceptionsAfterUnsubscribeboolIf true, exceptions that occur after cancellation has been initiated by unsubscribing from the observable this method returns will be handled and silently ignored. If false, they will go unobserved, meaning they will eventually emerge through UnobservedTaskException.

Returns: IQbservable -- An observable sequence whose observers trigger the given asynchronous observable factory function to be started.

Remarks

When a subscription to the resulting sequence is disposed, the CancellationToken that was fed to the asynchronous observable factory function will be signaled.

Exceptions

TypeCondition
System.ArgumentNullExceptionobservableFactoryAsync is null.