Interface IReactorBuilder

Namespace

Cratis.Chronicle.Reactors

Assembly

Cratis.Chronicle.dll

Defines a builder for declaring a reactor fluently, with handlers for the events it reacts to.

public interface IReactorBuilder

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>)

Remarks

Handlers are awaited, and an event is only acknowledged once every handler for it has completed. A handler that throws or returns a failed task fails the event's partition, exactly as a failing method on a discovered reactor does.

When an event has typed handlers and the reactor also has catch-all handlers, the typed handlers run first, in the order they were declared, followed by the catch-all handlers in the order they were declared.

Methods

NotReplayable()

Disables replay for the reactor, for handlers whose side effects must not be repeated.

IReactorBuilder NotReplayable()

Returns

IReactorBuilder

The builder for continuation.

OnEventSequence(EventSequenceId)

Selects the event sequence to observe. Defaults to the event log.

IReactorBuilder OnEventSequence(EventSequenceId eventSequenceId)

Parameters

eventSequenceId EventSequenceId

The event sequence.

Returns

IReactorBuilder

The builder for continuation.

On<TEvent>(Action<TEvent, EventContext>)

Handle a specific event type, with its EventContext.

IReactorBuilder On<TEvent>(Action<TEvent, EventContext> handler)

Parameters

handler Action<TEvent, EventContext>

The handler receiving the event and its context.

Returns

IReactorBuilder

The builder for continuation.

Type Parameters

TEvent

The event type to handle. Subscribes the reactor to this event type only.

Exceptions

TypeIsNotAnEventType

Thrown when TEvent is not a known event type.

On<TEvent>(Action<TEvent>)

Handle a specific event type.

IReactorBuilder On<TEvent>(Action<TEvent> handler)

Parameters

handler Action<TEvent>

The handler receiving the event.

Returns

IReactorBuilder

The builder for continuation.

Type Parameters

TEvent

The event type to handle. Subscribes the reactor to this event type only.

Exceptions

TypeIsNotAnEventType

Thrown when TEvent is not a known event type.

On<TEvent>(Func<TEvent, EventContext, Task>)

Handle a specific event type asynchronously, with its EventContext.

IReactorBuilder On<TEvent>(Func<TEvent, EventContext, Task> handler)

Parameters

handler Func<TEvent, EventContext, Task>

The handler receiving the event and its context.

Returns

IReactorBuilder

The builder for continuation.

Type Parameters

TEvent

The event type to handle. Subscribes the reactor to this event type only.

Exceptions

TypeIsNotAnEventType

Thrown when TEvent is not a known event type.

On<TEvent>(Func<TEvent, Task>)

Handle a specific event type asynchronously.

IReactorBuilder On<TEvent>(Func<TEvent, Task> handler)

Parameters

handler Func<TEvent, Task>

The handler receiving the event.

Returns

IReactorBuilder

The builder for continuation.

Type Parameters

TEvent

The event type to handle. Subscribes the reactor to this event type only.

Exceptions

TypeIsNotAnEventType

Thrown when TEvent is not a known event type.

Subscribe(Action<object, EventContext>)

Handle every event, whatever its type. This makes the reactor an all-events subscription.

IReactorBuilder Subscribe(Action<object, EventContext> handler)

Parameters

handler Action<object, EventContext>

The handler receiving each event and its context.

Returns

IReactorBuilder

The builder for continuation.

Remarks

The subscription covers every event type this client knows when the reactor is defined - the event types discovered in the client's artifacts. An event type the client does not know cannot be turned into an object to hand to the handler, so it is not part of the subscription; nor is an event type that becomes known only after the reactor was defined. EventTypes tells exactly which event types that is.

Subscribe(Func<object, EventContext, Task>)

Handle every event asynchronously, whatever its type. This makes the reactor an all-events subscription.

IReactorBuilder Subscribe(Func<object, EventContext, Task> handler)

Parameters

handler Func<object, EventContext, Task>

The handler receiving each event and its context.

Returns

IReactorBuilder

The builder for continuation.

Remarks

The subscription covers the same event types as Subscribe(Action<object, EventContext>) describes.