Method SelectAsync

SelectAsync<T, T1>(IObservable<T>, Func<T, CancellationToken, Task<T1>>)

Declaration
public static IObservable<T1> SelectAsync<T, T1>(this IObservable<T> observable, Func<T, CancellationToken, Task<T1>> supplier)
Parameters
Type Name Description
IObservable<T> observable
Func<T, CancellationToken, Task<T1>> supplier
Returns
Type Description
IObservable<T1>
Type Parameters
Name Description
T
T1

SelectAsync<T, T1>(IObservable<T>, Func<T, Task<T1>>)

Declaration
public static IObservable<T1> SelectAsync<T, T1>(this IObservable<T> observable, Func<T, Task<T1>> supplier)
Parameters
Type Name Description
IObservable<T> observable
Func<T, Task<T1>> supplier
Returns
Type Description
IObservable<T1>
Type Parameters
Name Description
T
T1

SelectAsync<T, T1>(IObservable<T>, Func<T, Task<T1>>, IScheduler)

Declaration
public static IObservable<T1> SelectAsync<T, T1>(this IObservable<T> observable, Func<T, Task<T1>> supplier, IScheduler scheduler)
Parameters
Type Name Description
IObservable<T> observable
Func<T, Task<T1>> supplier
IScheduler scheduler
Returns
Type Description
IObservable<T1>
Type Parameters
Name Description
T
T1

SelectAsync<T>(IObservable<T>, Func<T, Task>, IScheduler)

Declaration
public static IObservable<Unit> SelectAsync<T>(this IObservable<T> observable, Func<T, Task> supplier, IScheduler scheduler)
Parameters
Type Name Description
IObservable<T> observable
Func<T, Task> supplier
IScheduler scheduler
Returns
Type Description
IObservable<Unit>
Type Parameters
Name Description
T