Class IntervalEventSource

Namespace

LfrlAnvil.Reactive.Chrono.Internal

Assembly

LfrlAnvil.Reactive.Chrono.dll

Represents a disposable event source that can be listened to, that notifies its listeners with events published by an underlying ReactiveTimer created per listener.

public sealed class IntervalEventSource : EventSource<WithInterval<long>>, IEventSource<WithInterval<long>>, IEventStream<WithInterval<long>>, IEventSource, IEventStream, IDisposable

Inheritance

object

EventSource<WithInterval<long>>

IntervalEventSource

Implements

IEventSource<WithInterval<long>>

IEventStream<WithInterval<long>>

IEventSource

IEventStream

IDisposable

Inherited Members

EventSource<WithInterval<long>>.IsDisposed

EventSource<WithInterval<long>>.Subscribers

EventSource<WithInterval<long>>.HasSubscribers

EventSource<WithInterval<long>>.Dispose()

EventSource<WithInterval<long>>.Listen(IEventListener<WithInterval<long>>)

EventSource<WithInterval<long>>.Decorate<TNextEvent>(IEventListenerDecorator<WithInterval<long>, TNextEvent>)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

EventStreamExtensions.Delay<TEvent>(IEventStream<TEvent>, ITimestampProvider, Duration)

EventStreamExtensions.Delay<TEvent>(IEventStream<TEvent>, ITimestampProvider, Duration, Duration)

EventStreamExtensions.Delay<TEvent>(IEventStream<TEvent>, ITimestampProvider, Duration, TaskScheduler)

EventStreamExtensions.Delay<TEvent>(IEventStream<TEvent>, ITimestampProvider, Duration, TaskScheduler, Duration)

EventStreamExtensions.RegisterTasks<TKey>(IEventStream<WithInterval<long>>, IEnumerable<ITimerTask<TKey>>)

EventStreamExtensions.WithInterval<TEvent>(IEventStream<TEvent>, ITimestampProvider)

EventStreamExtensions.WithTimestamp<TEvent>(IEventStream<TEvent>, ITimestampProvider)

EventStreamExtensions.WithZonedDateTime<TEvent>(IEventStream<TEvent>, IZonedClock)

Methods

OverrideListener(IEventSubscriber, IEventListener<WithInterval<long>>)

Allows to override the event listener.

protected override IEventListener<WithInterval<long>> OverrideListener(IEventSubscriber subscriber, IEventListener<WithInterval<long>> listener)

Parameters

subscriber IEventSubscriber

Event subscriber.

listener IEventListener<WithInterval<long>>

Event listener to override.

Returns

IEventListener<WithInterval<long>>

IEventListener<TEvent> instance.