<PackageReference Include="System.Reactive" Version="4.3.1" />

ObservableExtensions

public static class ObservableExtensions
Provides a set of static methods for subscribing delegates to observables.
public static IDisposable Subscribe<T>(this IObservable<T> source)

Subscribes to the observable sequence without specifying any handlers. This method can be used to evaluate the observable sequence for its side-effects only.

public static IDisposable Subscribe<T>(this IObservable<T> source, Action<T> onNext)

Subscribes an element handler to an observable sequence.

public static IDisposable Subscribe<T>(this IObservable<T> source, Action<T> onNext, Action<Exception> onError)

Subscribes an element handler and an exception handler to an observable sequence.

public static IDisposable Subscribe<T>(this IObservable<T> source, Action<T> onNext, Action onCompleted)

Subscribes an element handler and a completion handler to an observable sequence.

public static IDisposable Subscribe<T>(this IObservable<T> source, Action<T> onNext, Action<Exception> onError, Action onCompleted)

Subscribes an element handler, an exception handler, and a completion handler to an observable sequence.

public static void Subscribe<T>(this IObservable<T> source, IObserver<T> observer, CancellationToken token)

Subscribes an observer to an observable sequence, using a CancellationToken to support unsubscription.

public static void Subscribe<T>(this IObservable<T> source, CancellationToken token)

Subscribes to the observable sequence without specifying any handlers, using a CancellationToken to support unsubscription. This method can be used to evaluate the observable sequence for its side-effects only.

public static void Subscribe<T>(this IObservable<T> source, Action<T> onNext, CancellationToken token)

Subscribes an element handler to an observable sequence, using a CancellationToken to support unsubscription.

public static void Subscribe<T>(this IObservable<T> source, Action<T> onNext, Action<Exception> onError, CancellationToken token)

Subscribes an element handler and an exception handler to an observable sequence, using a CancellationToken to support unsubscription.

public static void Subscribe<T>(this IObservable<T> source, Action<T> onNext, Action onCompleted, CancellationToken token)

Subscribes an element handler and a completion handler to an observable sequence, using a CancellationToken to support unsubscription.

public static void Subscribe<T>(this IObservable<T> source, Action<T> onNext, Action<Exception> onError, Action onCompleted, CancellationToken token)

Subscribes an element handler, an exception handler, and a completion handler to an observable sequence, using a CancellationToken to support unsubscription.

public static IDisposable SubscribeSafe<T>(this IObservable<T> source, IObserver<T> observer)

Subscribes to the specified source, re-routing synchronous exceptions during invocation of the Subscribe method to the observer's OnError channel. This method is typically used when writing query operators.