Class MaterializedReadModelDiffer

Namespace

Cratis.Chronicle.ReadModels

Assembly

Cratis.Chronicle.dll

Detects added, modified and removed read model instances by diffing successive materialized windows.

public class MaterializedReadModelDiffer

Inheritance

object

MaterializedReadModelDiffer

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

Remarks

The materialized API delivers a full window of instances on every change. Because the deserialized read model no longer carries the last handled event sequence number, change type is determined by comparing the serialized value of each instance — keyed by its id property — against the previous window.

Constructors

MaterializedReadModelDiffer(JsonSerializerOptions)

Detects added, modified and removed read model instances by diffing successive materialized windows.

public MaterializedReadModelDiffer(JsonSerializerOptions jsonSerializerOptions)

Parameters

jsonSerializerOptions JsonSerializerOptions

The JsonSerializerOptions used to serialize instances for comparison.

Remarks

The materialized API delivers a full window of instances on every change. Because the deserialized read model no longer carries the last handled event sequence number, change type is determined by comparing the serialized value of each instance — keyed by its id property — against the previous window.

Methods

Diff(IEnumerable<object>)

Diff the given window of instances against the previous window.

public IReadOnlyList<MaterializedReadModelChange> Diff(IEnumerable<object> window)

Parameters

window IEnumerable<object>

The current window of read model instances.

Returns

IReadOnlyList<MaterializedReadModelChange>

The changes between the previous window and this one.