<PackageReference Include="Relativity.Transfer.Client" Version="7.2.7" />

Observer

public static class Observer
public static IObserver<T> AsObserver<T>(this IObserver<T> observer)

public static IObserver<T> Checked<T>(this IObserver<T> observer)

public static IObserver<T> Create<T>(Action<T> onNext)

public static IObserver<T> Create<T>(Action<T> onNext, Action<Exception> onError)

public static IObserver<T> Create<T>(Action<T> onNext, Action onCompleted)

public static IObserver<T> Create<T>(Action<T> onNext, Action<Exception> onError, Action onCompleted)

public static IObserver<T> NotifyOn<T>(this IObserver<T> observer, IScheduler scheduler)

public static IObserver<T> NotifyOn<T>(this IObserver<T> observer, SynchronizationContext context)

public static IObserver<T> Synchronize<T>(IObserver<T> observer)

public static IObserver<T> Synchronize<T>(IObserver<T> observer, bool preventReentrancy)

public static IObserver<T> Synchronize<T>(IObserver<T> observer, object gate)

public static IObserver<T> Synchronize<T>(IObserver<T> observer, AsyncLock asyncLock)

public static Action<Notification<T>> ToNotifier<T>(this IObserver<T> observer)

public static IObserver<T> ToObserver<T>(this Action<Notification<T>> handler)

public static IObserver<T> ToObserver<T>(this IProgress<T> progress)

public static IProgress<T> ToProgress<T>(this IObserver<T> observer)

public static IProgress<T> ToProgress<T>(this IObserver<T> observer, IScheduler scheduler)