Namespace LfrlAnvil.Reactive.Internal

CombineEventSource<TEvent>: Represents a generic disposable event source that can be listened to, that notifies its listeners when any of the inner event streams publishes an event, with a sequence of last events published by inner event streams. First event will be published once all inner event streams publish at least one event. Event listeners will be disposed when all inner event streams get disposed or when the first event has not been published yet and any of the inner streams gets disposed.

ConcurrentEventPublisher<TEvent, TPublisher>: Represents a concurrent version of an EventPublisher<TEvent>.

ConcurrentEventSource<TEvent, TSource>: Represents a concurrent version of a generic disposable event source that can be listened to.

ConcurrentHistoryEventPublisher<TEvent, TPublisher>: Represents a concurrent version of a HistoryEventPublisher<TEvent>.

EnumerableEventSource<TEvent>: Represents a generic disposable event source that can be listened to, that notifies its listeners immediately with all stored events sequentially, and then disposes the listener.

MergeEventSource<TEvent>: Represents a generic disposable event source that can be listened to, that notifies its listeners with events published by any of its inner event streams. Number of maximum active inner event streams can be limited, in which case the inner event streams are activated sequentially. Event listener gets disposed once all inner event streams get disposed.

TaskEventSource<TEvent>: Represents a generic disposable event source that can be listened to, that notifies its listeners with a single event when the created Task<TResult> completes, and then disposes the listener. When an event subscriber gets disposed before the task completes, then the underlying CancellationTokenSource will request cancellation.

WhenAllEventSource<TEvent>: Represents a generic disposable event source that can be listened to, that notifies its listeners once all inner event sources are disposed, with a sequence of last inner event source events, and then disposes the listener.

WhenAnyEventSource<TEvent>: Represents a generic disposable event source that can be listened to, that notifies its listeners once any inner event source is disposed, with the last event published by that disposed inner event source, and then disposes the listener.