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

Observable.FromAsync(Func>) method¶

Overloads¶

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

1. Overload¶

public static IObservable<TResult> FromAsync<TResult>(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: IObservable -- An observable sequence exposing the result of invoking the function, or an exception.

Exceptions

2. Overload¶

public static IObservable<TResult> FromAsync<TResult>(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: IObservable -- An observable sequence exposing the result of invoking the function, or an exception.

Exceptions

3. Overload¶

public static IObservable<TResult> FromAsync<TResult>(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: IObservable -- An observable sequence exposing the result of invoking the function, or an exception.

Exceptions

4. Overload¶

public static IObservable<TResult> FromAsync<TResult>(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: IObservable -- 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

5. Overload¶

public static IObservable<TResult> FromAsync<TResult>(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: IObservable -- 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

6. Overload¶

public static IObservable<TResult> FromAsync<TResult>(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: IObservable -- 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

7. Overload¶

public static IObservable<Unit> FromAsync(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: IObservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Exceptions

8. Overload¶

public static IObservable<Unit> FromAsync(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: IObservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Exceptions

9. Overload¶

public static IObservable<Unit> FromAsync(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: IObservable -- An observable sequence exposing a Unit value upon completion of the action, or an exception.

Exceptions

10. Overload¶

public static IObservable<Unit> FromAsync(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: IObservable -- 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

11. Overload¶

public static IObservable<Unit> FromAsync(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: IObservable -- 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

12. Overload¶

public static IObservable<Unit> FromAsync(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: IObservable -- 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