System.Reactive.Subjects.AsyncSubject<T>

AsyncSubject<T>

public sealed class AsyncSubject<T> : SubjectBase<T>, INotifyCompletion

Represents the result of an asynchronous operation. The last value before the OnCompleted notification, or the error received through OnError, is sent to all subscribed observers.

Documentation
Code

public bool IsCompleted { get; }

Gets whether the AsyncSubject has completed.

public AsyncSubject()

Creates a subject that can only receive one value and that value is cached for all future observations.

public AsyncSubject<T> GetAwaiter()

Gets an awaitable object for the current AsyncSubject.

public T GetResult()

Gets the last element of the subject, potentially blocking until the subject completes successfully or exceptionally.

public void OnCompleted(Action continuation)

Specifies a callback action that will be invoked when the subject completes.