Method SubscribeAsync

SubscribeAsync<T>(IObservable<T>, Func<Task>)

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

SubscribeAsync<T>(IObservable<T>, Func<T, Task>)

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

SubscribeAsync<T>(IObservable<T>, Func<Task>, Action<Exception>)

Declaration
public static IDisposable SubscribeAsync<T>(this IObservable<T> observable, Func<Task> supplier, Action<Exception> onError)
Parameters
Type Name Description
IObservable<T> observable
Func<Task> supplier
Action<Exception> onError
Returns
Type Description
IDisposable
Type Parameters
Name Description
T

SubscribeAsync<T>(IObservable<T>, Func<T, CancellationToken, Task>)

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

SubscribeAsync<T>(IObservable<T>, Func<T, CancellationToken, Task>, Action<Exception>)

Declaration
public static IDisposable SubscribeAsync<T>(this IObservable<T> observable, Func<T, CancellationToken, Task> supplier, Action<Exception> onError)
Parameters
Type Name Description
IObservable<T> observable
Func<T, CancellationToken, Task> supplier
Action<Exception> onError
Returns
Type Description
IDisposable
Type Parameters
Name Description
T

SubscribeAsync<T>(IObservable<T>, Func<T, Task>, Action<Exception>)

Declaration
public static IDisposable SubscribeAsync<T>(this IObservable<T> observable, Func<T, Task> supplier, Action<Exception> onError)
Parameters
Type Name Description
IObservable<T> observable
Func<T, Task> supplier
Action<Exception> onError
Returns
Type Description
IDisposable
Type Parameters
Name Description
T