Method SubscribeSafe

SubscribeSafe<T>(IObservable<T>, Action, Action<Exception>)

Declaration
public static IDisposable SubscribeSafe<T>(this IObservable<T> source, Action onNext, Action<Exception> onError)
Parameters
Type Name Description
IObservable<T> source
Action onNext
Action<Exception> onError
Returns
Type Description
IDisposable
Type Parameters
Name Description
T

SubscribeSafe<T>(IObservable<T>, Action<T>, Action<Exception>)

Declaration
public static IDisposable SubscribeSafe<T>(this IObservable<T> source, Action<T> onNext, Action<Exception> onError)
Parameters
Type Name Description
IObservable<T> source
Action<T> onNext
Action<Exception> onError
Returns
Type Description
IDisposable
Type Parameters
Name Description
T

SubscribeSafe<T>(IObservable<T>, Action<T>, Action<Exception>, Action)

Declaration
public static IDisposable SubscribeSafe<T>(this IObservable<T> source, Action<T> onNext, Action<Exception> onError, Action onCompleted)
Parameters
Type Name Description
IObservable<T> source
Action<T> onNext
Action<Exception> onError
Action onCompleted
Returns
Type Description
IDisposable
Type Parameters
Name Description
T

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

Declaration
public static IDisposable SubscribeSafe<T>(this IObservable<T> source, Func<Task> asyncAction, Action<Exception> handler)
Parameters
Type Name Description
IObservable<T> source
Func<Task> asyncAction
Action<Exception> handler
Returns
Type Description
IDisposable
Type Parameters
Name Description
T

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

Declaration
public static IDisposable SubscribeSafe<T>(this IObservable<T> source, Func<T, Task> asyncAction, Action<Exception> handler)
Parameters
Type Name Description
IObservable<T> source
Func<T, Task> asyncAction
Action<Exception> handler
Returns
Type Description
IDisposable
Type Parameters
Name Description
T