Interface IOccurrenceHandler<TTrigger>

Namespace

Cratis.Chronicle.Occurrences

Assembly

Cratis.Chronicle.dll

Handles at-least-once delivery of a typed trigger. Use effect receipts for Chronicle writes and effect keys for external calls.

public interface IOccurrenceHandler<in TTrigger>

Type Parameters

TTrigger

The type marked with TriggerAttribute.

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

Methods

Handle(TTrigger, OccurrenceContext, CancellationToken)

Handles one leased attempt. Honor cancellation when the connection, lease or client lifetime ends.

Task Handle(TTrigger trigger, OccurrenceContext context, CancellationToken cancellationToken)

Parameters

trigger TTrigger

The recorded plaintext payload.

context OccurrenceContext

The durable identity and current attempt.

cancellationToken CancellationToken

Cancellation for the attempt.

Returns

Task

The asynchronous handler work.