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

Subject

public static class Subject
public static ISubject<TSource, TResult> Create<TSource, TResult>(IObserver<TSource> observer, IObservable<TResult> observable)

public static ISubject<T> Create<T>(IObserver<T> observer, IObservable<T> observable)

public static ISubject<TSource, TResult> Synchronize<TSource, TResult>(ISubject<TSource, TResult> subject)

public static ISubject<TSource> Synchronize<TSource>(ISubject<TSource> subject)

public static ISubject<TSource, TResult> Synchronize<TSource, TResult>(ISubject<TSource, TResult> subject, IScheduler scheduler)

public static ISubject<TSource> Synchronize<TSource>(ISubject<TSource> subject, IScheduler scheduler)