Class ScheduledSubject<T>
- Namespace
- ReactiveUI
- Assembly
- ReactiveUI.dll
A subject which dispatches all its events on the specified Scheduler.
public class ScheduledSubject<T> : ISubject<T>, ISubject<T, T>, IObserver<T>, IObservable<T>, IDisposable
Type Parameters
T
The type of item being dispatched by the Subject.
- Inheritance
-
ScheduledSubject<T>
- Implements
-
ISubject<T>ISubject<T, T>IObserver<T>IObservable<T>
- Extension Methods
Constructors
ScheduledSubject(IScheduler, IObserver<T>?, ISubject<T>?)
Initializes a new instance of the ScheduledSubject<T> class.
public ScheduledSubject(IScheduler scheduler, IObserver<T>? defaultObserver = null, ISubject<T>? defaultSubject = null)
Parameters
scheduler
ISchedulerThe scheduler where to dispatch items to.
defaultObserver
IObserver<T>A optional default observer where notifications will be sent.
defaultSubject
ISubject<T>A optional default subject which this Subject will wrap.
Methods
Dispose()
public void Dispose()
Dispose(bool)
Disposes of any managed resources in our class.
protected virtual void Dispose(bool isDisposing)
Parameters
isDisposing
boolIf we are being called by the IDisposable method.
OnCompleted()
public void OnCompleted()
OnError(Exception)
public void OnError(Exception error)
Parameters
error
Exception
OnNext(T)
public void OnNext(T value)
Parameters
value
T
Subscribe(IObserver<T>)
public IDisposable Subscribe(IObserver<T> observer)
Parameters
observer
IObserver<T>