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>>.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>, ValueTaskDelaySource, Duration, Duration, ITimestampProvider?)

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

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

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

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

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

Methods

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public override void Dispose()

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

Allows to override an event listener.

protected override IEventListener<WithInterval<long>> OverrideListenerUnsafe(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.

Remarks

This method call is not thread-safe by default.