Class ReactorSideEffectHandlers

Represents an implementation of IReactorSideEffectHandlers that dispatches reactor return values to all registered IReactorSideEffectHandler instances.

[Singleton]
public class ReactorSideEffectHandlers : IReactorSideEffectHandlers

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

Represents an implementation of IReactorSideEffectHandlers that dispatches reactor return values to all registered IReactorSideEffectHandler instances.

public ReactorSideEffectHandlers(IInstancesOf<IReactorSideEffectHandler> handlers)

handlers IInstancesOf<IReactorSideEffectHandler>: All registered IReactorSideEffectHandler instances.

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

public 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.

public 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.

public bool CanHandleReturnType(Type type)

Defaults to false for existing dispatcher implementations.

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

public 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.