Interface IReadModelReactorInvoker

Namespace

Cratis.Chronicle.ReadModels

Assembly

Cratis.Chronicle.dll

Defines a system that invokes a IReadModelReactor handler method for a read model change.

public interface IReadModelReactorInvoker

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

Invoke(IEventStore, object, ReadModelReactorMethod, object?, EventContext, IServiceProvider)

Invoke a read model reactor handler method for a change.

Task Invoke(IEventStore eventStore, object reactor, ReadModelReactorMethod method, object? readModel, EventContext changeContext, IServiceProvider serviceProvider)

Parameters

eventStore IEventStore

The IEventStore used to append any side-effect events.

reactor object

The reactor instance.

method ReadModelReactorMethod

The ReadModelReactorMethod to invoke.

readModel object

The read model instance that changed, if any.

changeContext EventContext

The EventContext of the event that caused the change.

serviceProvider IServiceProvider

The IServiceProvider used to resolve additional dependencies.

Returns

Task

A Task representing the asynchronous operation.