Interface IReactorSideEffectHandlers

Defines a system for managing IReactorSideEffectHandler instances and dispatching return values to them.

public interface IReactorSideEffectHandlers

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

Determines whether any registered handler can process the given return value.

bool CanHandle(ReactorContext reactorContext, IEventStore eventStore, object value)

reactorContext ReactorContext: The ReactorContext for the reactor invocation.
eventStore IEventStore: The IEventStore the reactor is running under.
value object: The value returned by the reactor handler method.

Defaults to the event-store-less overload so an implementation written against the previous contract keeps working unchanged.

Determines whether any registered handler can process the given return value.

bool CanHandle(ReactorContext reactorContext, object value)

reactorContext ReactorContext: The ReactorContext for the reactor invocation.
value object: The value returned by the reactor handler method.

Determines whether any registered handler claims a synchronous reactor return type.

bool CanHandleReturnType(Type type)

Defaults to false for existing dispatcher implementations.

Dispatches the return value to all handlers that can process it.

Task<Result<ReactorSideEffectFailure>> Handle(ReactorContext reactorContext, IEventStore eventStore, object value)

reactorContext ReactorContext: The ReactorContext for the reactor invocation.
eventStore IEventStore: The IEventStore to use for appending events.
value object: The value returned by the reactor handler method.

Task<Result<ReactorSideEffectFailure>>: A Task representing the asynchronous operation.