Class ReadModelReactors

Namespace

Cratis.Chronicle.ReadModels

Assembly

Cratis.Chronicle.dll

Represents an implementation of IReadModelReactors.

public class ReadModelReactors : IReadModelReactors, IDisposable

Inheritance

object

ReadModelReactors

Implements

IReadModelReactors

IDisposable

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

ReadModelReactors(IEventStore, IClientArtifactsProvider, IClientArtifactsActivator, IServiceProvider, IReadModelReactorInvoker, JsonSerializerOptions, ILogger<ReadModelReactors>)

Represents an implementation of IReadModelReactors.

public ReadModelReactors(IEventStore eventStore, IClientArtifactsProvider clientArtifactsProvider, IClientArtifactsActivator artifactActivator, IServiceProvider serviceProvider, IReadModelReactorInvoker invoker, JsonSerializerOptions jsonSerializerOptions, ILogger<ReadModelReactors> logger)

Parameters

eventStore IEventStore

The IEventStore the reactors belong to.

clientArtifactsProvider IClientArtifactsProvider

The IClientArtifactsProvider used to discover reactors.

artifactActivator IClientArtifactsActivator

The IClientArtifactsActivator used to activate reactor instances.

serviceProvider IServiceProvider

The IServiceProvider used to create dependency-resolution scopes.

invoker IReadModelReactorInvoker

The IReadModelReactorInvoker used to invoke handler methods.

jsonSerializerOptions JsonSerializerOptions

The JsonSerializerOptions used when diffing materialized instances.

logger ILogger<ReadModelReactors>

The ILogger<TCategoryName> for logging.

Methods

Dispose()

public void Dispose()

Start()

Discover all read model reactors and start watching the read models they react to.

public void Start()

Stop()

Stop watching and dispose of all subscriptions.

public void Stop()