Class ConcurrentEventHandlerSource<TEvent>

Namespace

LfrlAnvil.Reactive

Assembly

LfrlAnvil.Reactive.Core.dll

Represents a concurrent version of an EventHandlerSource<TEvent>.

public sealed class ConcurrentEventHandlerSource<TEvent> : ConcurrentEventSource<WithSender<TEvent>, EventHandlerSource<TEvent>>, IEventSource<WithSender<TEvent>>, IEventStream<WithSender<TEvent>>, IEventSource, IEventStream, IDisposable

Type Parameters

TEvent

Event type.

Inheritance

object

ConcurrentEventSource<WithSender<TEvent>, EventHandlerSource<TEvent>>

ConcurrentEventHandlerSource<TEvent>

Implements

IEventSource<WithSender<TEvent>>

IEventStream<WithSender<TEvent>>

IEventSource

IEventStream

IDisposable

Inherited Members

ConcurrentEventSource<WithSender<TEvent>, EventHandlerSource<TEvent>>.IsDisposed

ConcurrentEventSource<WithSender<TEvent>, EventHandlerSource<TEvent>>.Subscribers

ConcurrentEventSource<WithSender<TEvent>, EventHandlerSource<TEvent>>.HasSubscribers

ConcurrentEventSource<WithSender<TEvent>, EventHandlerSource<TEvent>>.Dispose()

ConcurrentEventSource<WithSender<TEvent>, EventHandlerSource<TEvent>>.Decorate<TNextEvent>(IEventListenerDecorator<WithSender<TEvent>, TNextEvent>)

ConcurrentEventSource<WithSender<TEvent>, EventHandlerSource<TEvent>>.Listen(IEventListener<WithSender<TEvent>>)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

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>, params TEvent[])

EventStreamExtensions.Append<TEvent>(IEventStream<TEvent>, IEnumerable<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>, params TEvent[])

EventStreamExtensions.Prepend<TEvent>(IEventStream<TEvent>, IEnumerable<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

ConcurrentEventHandlerSource(Action<EventHandler<TEvent>>, Action<EventHandler<TEvent>>)

Creates a new ConcurrentEventHandlerSource<TEvent> instance.

public ConcurrentEventHandlerSource(Action<EventHandler<TEvent>> setup, Action<EventHandler<TEvent>> teardown)

Parameters

setup Action<EventHandler<TEvent>>

Delegate that handles initialization of this event source.

teardown Action<EventHandler<TEvent>>

Delegate that handles disposal of this event source.