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

Subject

public static class Subject
Provides a set of static methods for creating subjects.
public static ISubject<TSource, TResult> Create<TSource, TResult>(IObserver<TSource> observer, IObservable<TResult> observable)

Creates a subject from the specified observer and observable.

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

Creates a subject from the specified observer and observable.

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

Synchronizes the messages sent to the subject.

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

Synchronizes the messages sent to the subject.

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

Synchronizes the messages sent to the subject and notifies observers on the specified scheduler.

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

Synchronizes the messages sent to the subject and notifies observers on the specified scheduler.