Interface IReactorMiddleware

Namespace

Cratis.Chronicle.Reactors

Assembly

Cratis.Chronicle.dll

Defines a middleware that can be called during the observing of events.

public interface IReactorMiddleware

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

Methods

AfterInvoke(EventContext, object)

Invoked after the actual invoke.

Task AfterInvoke(EventContext eventContext, object @event)

Parameters

eventContext EventContext

EventContext for the event.

event object

The actual event that it will be called with.

Returns

Task

A Task representing the result of the asynchronous operation.

AfterInvoke(ReactorId, EventContext, object)

Invoked after the actual invoke, for a known reactor.

Task AfterInvoke(ReactorId reactorId, EventContext eventContext, object @event)

Parameters

reactorId ReactorId

The ReactorId of the reactor the event was observed for.

eventContext EventContext

EventContext for the event.

event object

The actual event that it will be called with.

Returns

Task

A Task representing the result of the asynchronous operation.

Remarks

This is the overload Chronicle calls. It defaults to the overload without the reactor, so a middleware written before the reactor was passed along keeps working; implement this one to know which reactor is running.

BeforeInvoke(EventContext, object)

Invoked before the actual invoke.

Task BeforeInvoke(EventContext eventContext, object @event)

Parameters

eventContext EventContext

EventContext for the event.

event object

The actual event that it will be called with.

Returns

Task

A Task representing the result of the asynchronous operation.

BeforeInvoke(ReactorId, EventContext, object)

Invoked before the actual invoke, for a known reactor.

Task BeforeInvoke(ReactorId reactorId, EventContext eventContext, object @event)

Parameters

reactorId ReactorId

The ReactorId of the reactor the event is being observed for.

eventContext EventContext

EventContext for the event.

event object

The actual event that it will be called with.

Returns

Task

A Task representing the result of the asynchronous operation.

Remarks

This is the overload Chronicle calls. It defaults to the overload without the reactor, so a middleware written before the reactor was passed along keeps working; implement this one to know which reactor is running.