Class ReadModelReactorInvoker

Namespace

Cratis.Chronicle.ReadModels

Assembly

Cratis.Chronicle.dll

Represents an implementation of IReadModelReactorInvoker.

public class ReadModelReactorInvoker : IReadModelReactorInvoker

Inheritance

object

ReadModelReactorInvoker

Implements

IReadModelReactorInvoker

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

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

Constructors

ReadModelReactorInvoker(IReactorSideEffectHandlers, IReactorContextValuesBuilder, ILogger<ReadModelReactorInvoker>)

Represents an implementation of IReadModelReactorInvoker.

public ReadModelReactorInvoker(IReactorSideEffectHandlers sideEffectHandlers, IReactorContextValuesBuilder contextValuesBuilder, ILogger<ReadModelReactorInvoker> logger)

Parameters

sideEffectHandlers IReactorSideEffectHandlers

The IReactorSideEffectHandlers used to append returned events as side effects.

contextValuesBuilder IReactorContextValuesBuilder

The IReactorContextValuesBuilder used to resolve append-metadata for side-effect events.

logger ILogger<ReadModelReactorInvoker>

The ILogger<TCategoryName> for logging.

Methods

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

Invoke a read model reactor handler method for a change.

public 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.