})} },System.Reactive.Concurrency.TaskObservationOptions)} },System.Reactive.Concurrency.IScheduler)} })} },System.Reactive.Concurrency.TaskObservationOptions)} },System.Reactive.Concurrency.IScheduler)} }})} }})} }},System.Reactive.Concurrency.TaskObservationOptions)} }},System.Reactive.Concurrency.TaskObservationOptions)} }},System.Reactive.Concurrency.IScheduler)} }},System.Reactive.Concurrency.IScheduler)}

Qbservable.FromAsync(IQbservableProvider, Expression>) method¶

Overloads¶

• 1. public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<Task>> actionAsync)
• 2. public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<Task>> actionAsync, TaskObservationOptions options)
• 3. public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<Task>> actionAsync, IScheduler scheduler)
• 4. public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<CancellationToken, Task>> actionAsync)
• 5. public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<CancellationToken, Task>> actionAsync, TaskObservationOptions options)
• 6. public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<CancellationToken, Task>> actionAsync, IScheduler scheduler)
• 7. public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync)
• 8. public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<TResult>>> functionAsync)
• 9. public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync, TaskObservationOptions options)
• 10. public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<TResult>>> functionAsync, TaskObservationOptions options)
• 11. public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync, IScheduler scheduler)
• 12. public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<TResult>>> functionAsync, IScheduler scheduler)

1. Overload¶

public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<Task>> actionAsync)

Summary: Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started.

Parameters

Returns: IQbservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Exceptions

2. Overload¶

public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<Task>> actionAsync, TaskObservationOptions options)

Summary: Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started.

Parameters

Returns: IQbservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Exceptions

3. Overload¶

public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<Task>> actionAsync, IScheduler scheduler)

Summary: Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started.

Parameters

Returns: IQbservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Exceptions

4. Overload¶

public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<CancellationToken, Task>> actionAsync)

Summary: Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. The CancellationToken passed to the asynchronous action is tied to the observable sequence's subscription that triggered the action's invocation and can be used for best-effort cancellation.

Parameters

Returns: IQbservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Remarks

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

Exceptions

5. Overload¶

public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<CancellationToken, Task>> actionAsync, TaskObservationOptions options)

Summary: Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. The CancellationToken passed to the asynchronous action is tied to the observable sequence's subscription that triggered the action's invocation and can be used for best-effort cancellation.

Parameters

Returns: IQbservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Remarks

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

Exceptions

6. Overload¶

public static IQbservable<Unit> FromAsync(this IQbservableProvider provider, Expression<Func<CancellationToken, Task>> actionAsync, IScheduler scheduler)

Summary: Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. The CancellationToken passed to the asynchronous action is tied to the observable sequence's subscription that triggered the action's invocation and can be used for best-effort cancellation.

Parameters

Returns: IQbservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Remarks

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

Exceptions

7. Overload¶

public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync)

Summary: Converts an asynchronous function into an observable sequence. Each subscription to the resulting sequence causes the function to be started.

Type parameters

Parameters

Returns: IQbservable -- An observable sequence exposing the result of invoking the function, or an exception.

Exceptions

8. Overload¶

public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<TResult>>> functionAsync)

Summary: Converts an asynchronous function into an observable sequence. Each subscription to the resulting sequence causes the function to be started. The CancellationToken passed to the asynchronous function is tied to the observable sequence's subscription that triggered the function's invocation and can be used for best-effort cancellation.

Type parameters

Parameters

Returns: IQbservable -- An observable sequence exposing the result of invoking the function, or an exception.

Remarks

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

Exceptions

9. Overload¶

public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync, TaskObservationOptions options)

Summary: Converts an asynchronous function into an observable sequence. Each subscription to the resulting sequence causes the function to be started.

Type parameters

Parameters

Returns: IQbservable -- An observable sequence exposing the result of invoking the function, or an exception.

Exceptions

10. Overload¶

public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<TResult>>> functionAsync, TaskObservationOptions options)

Summary: Converts an asynchronous function into an observable sequence. Each subscription to the resulting sequence causes the function to be started. The CancellationToken passed to the asynchronous function is tied to the observable sequence's subscription that triggered the function's invocation and can be used for best-effort cancellation.

Type parameters

Parameters

Returns: IQbservable -- An observable sequence exposing the result of invoking the function, or an exception.

Remarks

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

Exceptions

11. Overload¶

public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<Task<TResult>>> functionAsync, IScheduler scheduler)

Summary: Converts an asynchronous function into an observable sequence. Each subscription to the resulting sequence causes the function to be started.

Type parameters

Parameters

Returns: IQbservable -- An observable sequence exposing the result of invoking the function, or an exception.

Exceptions

12. Overload¶

public static IQbservable<TResult> FromAsync<TResult>(this IQbservableProvider provider, Expression<Func<CancellationToken, Task<TResult>>> functionAsync, IScheduler scheduler)

Summary: Converts an asynchronous function into an observable sequence. Each subscription to the resulting sequence causes the function to be started. The CancellationToken passed to the asynchronous function is tied to the observable sequence's subscription that triggered the function's invocation and can be used for best-effort cancellation.

Type parameters

Parameters

Returns: IQbservable -- An observable sequence exposing the result of invoking the function, or an exception.

Remarks

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

Exceptions