Class ConcurrentHistoryEventPublisher<TEvent, TPublisher>

Namespace

LfrlAnvil.Reactive.Internal

Assembly

LfrlAnvil.Reactive.Core.dll

Represents a concurrent version of a HistoryEventPublisher<TEvent>.

public class ConcurrentHistoryEventPublisher<TEvent, TPublisher> : ConcurrentEventPublisher<TEvent, TPublisher>, IHistoryEventPublisher<TEvent>, IEventPublisher<TEvent>, IEventSource<TEvent>, IEventStream<TEvent>, IEventPublisher, IEventSource, IEventStream, IDisposable where TPublisher : HistoryEventPublisher<TEvent>

Type Parameters

TEvent

Event type.

TPublisher

Underlying history event publisher type.

Inheritance

object

ConcurrentEventSource<TEvent, TPublisher>

ConcurrentEventPublisher<TEvent, TPublisher>

ConcurrentHistoryEventPublisher<TEvent, TPublisher>

Implements

IHistoryEventPublisher<TEvent>

IEventPublisher<TEvent>

IEventSource<TEvent>

IEventStream<TEvent>

IEventPublisher

IEventSource

IEventStream

IDisposable

Inherited Members

ConcurrentEventPublisher<TEvent, TPublisher>.Publish(TEvent)

ConcurrentEventSource<TEvent, TPublisher>.Base

ConcurrentEventSource<TEvent, TPublisher>.Sync

ConcurrentEventSource<TEvent, TPublisher>.IsDisposed

ConcurrentEventSource<TEvent, TPublisher>.Subscribers

ConcurrentEventSource<TEvent, TPublisher>.HasSubscribers

ConcurrentEventSource<TEvent, TPublisher>.Dispose()

ConcurrentEventSource<TEvent, TPublisher>.Decorate<TNextEvent>(IEventListenerDecorator<TEvent, TNextEvent>)

ConcurrentEventSource<TEvent, TPublisher>.Listen(IEventListener<TEvent>)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

EventStreamExtensions.Aggregate<TEvent>(IEventStream<TEvent>, Func<TEvent, TEvent, TEvent>)

EventStreamExtensions.Aggregate<TEvent>(IEventStream<TEvent>, Func<TEvent, TEvent, TEvent>, TEvent)

EventStreamExtensions.Append<TEvent>(IEventStream<TEvent>, IEnumerable<TEvent>)

EventStreamExtensions.Append<TEvent>(IEventStream<TEvent>, params TEvent[])

EventStreamExtensions.AuditUntil<TEvent, TTargetEvent>(IEventStream<TEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.BufferUntil<TEvent, TTargetEvent>(IEventStream<TEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.Buffer<TEvent>(IEventStream<TEvent>, int)

EventStreamExtensions.Catch<TEvent, TException>(IEventStream<TEvent>, Action<TException>)

EventStreamExtensions.Concurrent<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.Concurrent<TEvent>(IEventStream<TEvent>, object)

EventStreamExtensions.ContinueWith<TEvent, TNextEvent>(IEventStream<TEvent>, Func<TEvent, IEventStream<TNextEvent>>)

EventStreamExtensions.DebounceUntil<TEvent, TTargetEvent>(IEventStream<TEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.DefaultIfEmpty<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.DefaultIfEmpty<TEvent>(IEventStream<TEvent>, TEvent)

EventStreamExtensions.DistinctByUntilChanged<TEvent, TKey>(IEventStream<TEvent>, Func<TEvent, TKey>)

EventStreamExtensions.DistinctByUntilChanged<TEvent, TKey>(IEventStream<TEvent>, Func<TEvent, TKey>, IEqualityComparer<TKey>)

EventStreamExtensions.DistinctByUntil<TEvent, TKey, TTargetEvent>(IEventStream<TEvent>, Func<TEvent, TKey>, IEventStream<TTargetEvent>)

EventStreamExtensions.DistinctByUntil<TEvent, TKey, TTargetEvent>(IEventStream<TEvent>, Func<TEvent, TKey>, IEqualityComparer<TKey>, IEventStream<TTargetEvent>)

EventStreamExtensions.DistinctBy<TEvent, TKey>(IEventStream<TEvent>, Func<TEvent, TKey>)

EventStreamExtensions.DistinctBy<TEvent, TKey>(IEventStream<TEvent>, Func<TEvent, TKey>, IEqualityComparer<TKey>)

EventStreamExtensions.DistinctUntilChanged<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.DistinctUntilChanged<TEvent>(IEventStream<TEvent>, IEqualityComparer<TEvent>)

EventStreamExtensions.DistinctUntil<TEvent, TTargetEvent>(IEventStream<TEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.DistinctUntil<TEvent, TTargetEvent>(IEventStream<TEvent>, IEqualityComparer<TEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.Distinct<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.Distinct<TEvent>(IEventStream<TEvent>, IEqualityComparer<TEvent>)

EventStreamExtensions.ElementAt<TEvent>(IEventStream<TEvent>, int)

EventStreamExtensions.First<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.Flatten<TSourceEvent, TInnerEvent>(IEventStream<TSourceEvent>, Func<TSourceEvent, IEnumerable<TInnerEvent>>)

EventStreamExtensions.Flatten<TSourceEvent, TInnerEvent, TNextEvent>(IEventStream<TSourceEvent>, Func<TSourceEvent, IEnumerable<TInnerEvent>>, Func<TSourceEvent, TInnerEvent, TNextEvent>)

EventStreamExtensions.ForEach<TEvent>(IEventStream<TEvent>, Action<TEvent>)

EventStreamExtensions.GroupBy<TEvent, TKey>(IEventStream<TEvent>, Func<TEvent, TKey>)

EventStreamExtensions.GroupBy<TEvent, TKey>(IEventStream<TEvent>, Func<TEvent, TKey>, IEqualityComparer<TKey>)

EventStreamExtensions.Ignore<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.Last<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.Prepend<TEvent>(IEventStream<TEvent>, IEnumerable<TEvent>)

EventStreamExtensions.Prepend<TEvent>(IEventStream<TEvent>, params TEvent[])

EventStreamExtensions.SampleWhen<TEvent, TTargetEvent>(IEventStream<TEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.SelectMany<TSourceEvent, TNextEvent>(IEventStream<TSourceEvent>, Func<TSourceEvent, IEnumerable<TNextEvent>>)

EventStreamExtensions.Select<TSourceEvent, TNextEvent>(IEventStream<TSourceEvent>, Func<TSourceEvent, TNextEvent>)

EventStreamExtensions.ShareConcurrencyWith<TEvent, TTargetEvent, TResult>(IEventStream<TEvent>, IEventStream<TTargetEvent>, Func<IEventStream<TEvent>, IEventStream<TTargetEvent>, TResult>)

EventStreamExtensions.ShareConcurrencyWith<TEvent, TTargetEvent, TResult>(IEventStream<TEvent>, IEventStream<TTargetEvent>, Func<IEventStream<TEvent>, IEventStream<TTargetEvent>, TResult>, object)

EventStreamExtensions.Single<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.SkipLast<TEvent>(IEventStream<TEvent>, int)

EventStreamExtensions.SkipUntil<TEvent, TTargetEvent>(IEventStream<TEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.SkipWhile<TEvent>(IEventStream<TEvent>, Func<TEvent, bool>)

EventStreamExtensions.Skip<TEvent>(IEventStream<TEvent>, int)

EventStreamExtensions.TakeLast<TEvent>(IEventStream<TEvent>, int)

EventStreamExtensions.TakeUntil<TEvent, TTargetEvent>(IEventStream<TEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.TakeWhile<TEvent>(IEventStream<TEvent>, Func<TEvent, bool>)

EventStreamExtensions.Take<TEvent>(IEventStream<TEvent>, int)

EventStreamExtensions.ThrottleUntil<TEvent, TTargetEvent>(IEventStream<TEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.ToTask<TEvent>(IEventStream<TEvent>, CancellationToken)

EventStreamExtensions.UseSynchronizationContext<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.WhereNotNull<TEvent>(IEventStream<TEvent?>, IEqualityComparer<TEvent>)

EventStreamExtensions.Where<TEvent>(IEventStream<TEvent>, Func<TEvent, bool>)

EventStreamExtensions.WithIndex<TEvent>(IEventStream<TEvent>)

EventStreamExtensions.Zip<TSourceEvent, TTargetEvent>(IEventStream<TSourceEvent>, IEventStream<TTargetEvent>)

EventStreamExtensions.Zip<TSourceEvent, TTargetEvent, TNextEvent>(IEventStream<TSourceEvent>, IEventStream<TTargetEvent>, Func<TSourceEvent, TTargetEvent, TNextEvent>)

Constructors

ConcurrentHistoryEventPublisher(TPublisher)

Creates a new ConcurrentHistoryEventPublisher<TEvent, TPublisher> instance.

protected ConcurrentHistoryEventPublisher(TPublisher @base)

Parameters

base TPublisher

Underlying history event publisher.

Properties

Capacity

Specifies the maximum number of events this event publisher can record.

public int Capacity { get; }

Property Value

int

History

Collection of recorded previously published events.

public IReadOnlyCollection<TEvent> History { get; }

Property Value

IReadOnlyCollection<TEvent>

Methods

ClearHistory()

Removes all recorded events.

public void ClearHistory()