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

FastImmediateObserver<T>

Specialized scheduled observer similar to a scheduled observer for the immediate scheduler.
public FastImmediateObserver(IObserver<T> observer)

Creates a new scheduled observer that proxies to the specified observer.

public void Dispose()

Disposes the observer.

public void EnsureActive()

Notifies the observer of pending work. This will either cause the current owner to process the newly enqueued notifications, or it will cause the calling thread to become the owner and start processing the notification queue.

public void EnsureActive(int count)

Notifies the observer of pending work. This will either cause the current owner to process the newly enqueued notifications, or it will cause the calling thread to become the owner and start processing the notification queue.

public void OnCompleted()

Enqueues an OnCompleted notification.

public void OnError(Exception error)

Enqueues an OnError notification.

public void OnNext(T value)

Enqueues an OnNext notification.