Interface IReactorDefinition

Namespace

Cratis.Chronicle.Reactors

Assembly

Cratis.Chronicle.dll

Defines a reactor declared fluently through an IReactorBuilder, which can be inspected before and after it is registered.

public interface IReactorDefinition

Extension Methods

MethodCalls.CallGenericMethod<TOut, T>(T, Expression<Func<T, Func<TOut>>>, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1>(T, Expression<Func<T, Func<T1, TOut>>>, T1, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2>(T, Expression<Func<T, Func<T1, T2, TOut>>>, T1, T2, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2, T3>(T, Expression<Func<T, Func<T1, T2, T3, TOut>>>, T1, T2, T3, params Type[])

ConverterExtensions.ConvertTo(object, Type)

ConceptExtensions.GetConceptValue(object)

ConceptExtensions.IsConcept(object)

JsonValueExtensions.ToJsonValue(object?)

ObservableExtensions.InvokeAndWrapWithSubject<TResult>(object, Func<CancellationToken, IObservable<TResult>>)

ObservableExtensions.InvokeAndWrapWithTransformSubject<TResult, TSource>(object, Func<CancellationToken, IObservable<TSource>>, Func<TSource, TResult>)

Properties

ClrTypes

Gets the CLR types of the events the reactor subscribes to, one for each of the EventTypes.

IEnumerable<Type> ClrTypes { get; }

Property Value

IEnumerable<Type>

EventSequenceId

Gets the event sequence the reactor observes.

EventSequenceId EventSequenceId { get; }

Property Value

EventSequenceId

EventTypes

Gets the event types the reactor subscribes to - exactly the set Chronicle is asked to deliver.

IEnumerable<EventType> EventTypes { get; }

Property Value

IEnumerable<EventType>

Remarks

For a reactor with only typed handlers this is one event type per handled type. For an all-events subscription it is every event type the client knew when the reactor was defined, in its latest generation unless a typed handler names a different one.

Id

Gets the identifier of the reactor.

ReactorId Id { get; }

Property Value

ReactorId

IsReplayable

Gets a value indicating whether the reactor can be replayed.

bool IsReplayable { get; }

Property Value

bool

SubscribesToAllEvents

Gets a value indicating whether the reactor subscribes to all events, through Subscribe(Action<object, EventContext>) or its asynchronous equivalent.

bool SubscribesToAllEvents { get; }

Property Value

bool

Methods

Handle(object, EventContext)

Dispatch an event to the handlers that apply to it, the way the reactor does for every delivered event.

Task Handle(object @event, EventContext context)

Parameters

event object

The event to dispatch.

context EventContext

The EventContext of the event.

Returns

Task

Awaitable task, completing when every applicable handler has completed.

Remarks

Typed handlers apply when the event's type is exactly the type they were declared for; catch-all handlers apply to every event. An event no handler applies to is ignored.