Interface IReadModelReactor

Namespace

Cratis.Chronicle.ReadModels

Assembly

Cratis.Chronicle.dll

Marker interface for a read model reactor — a type that reacts to read model instances being added, modified or removed.

public interface IReadModelReactor

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

Method dispatch is by convention. A method named Added, Modified or Removed is invoked for the corresponding change. The first parameter is the read model — either a single instance or an IEnumerable<T> of instances — and determines which read model is watched. Further parameters are resolved as dependencies (the EventContext of the causing event or services from the service provider). Methods may be synchronous or asynchronous and may return events to be appended as side effects, exactly like reactors.