Interface IInterceptReadModel<TReadModel>

Namespace

Cratis.Arc.Queries

Assembly

Cratis.Arc.Core.dll

Defines a contract for intercepting a read model before it is served to a client.

public interface IInterceptReadModel<TReadModel>

Type Parameters

TReadModel

Type of read model to intercept.

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

Implement this interface to perform cross-cutting operations on read models, such as decryption or other transformations, both for regular and observable queries. Because read models are typically immutable records, interceptors receive the current instance and must return the (potentially replaced) instance — they must not mutate the original in place.

Methods

Intercept(TReadModel)

Intercepts the given read model and returns the intercepted result.

Task<TReadModel> Intercept(TReadModel readModel)

Parameters

readModel TReadModel

The read model instance to intercept.

Returns

Task<TReadModel>

A Task<TResult> that resolves to the intercepted read model, which may be a new instance.