streamline
library
Properties
-
$aggregate
→ Future<List<TResult>> Function<TResult>(IAggregator<TResult> aggregator)
-
Processes an aggregator through all registered handlers and returns
their results.
final
-
$aggregatorHandler
→ void Function<TActionType extends IAction<TResultType>, TResultType>(IActionHandler<TActionType, TResultType> handlerFactory())
-
Registers an aggregator handler factory for a specific IAggregator.
final
-
$commandHandler
→ void Function<TActionType extends IAction<TResultType>, TResultType>(IActionHandler<TActionType, TResultType> handlerFactory())
-
Registers a command handler factory for a specific ICommand.
final
-
$dispatch
→ Future<TResult> Function<TResult>(ICommand<TResult> command)
-
Dispatches a command to its registered handler and returns the result.
final
-
$emit
→ void Function<TEvent extends IEvent>(TEvent event, {bool skipIfSameAsLastEmitted = true})
-
Emits an event to all registered handlers and observers.
final
-
$eventHandler
→ void Function<TActionType extends IAction<TResultType>, TResultType>(IActionHandler<TActionType, TResultType> handlerFactory())
-
Registers an event handler factory for a specific IEvent.
final
-
$eventObserver
→ void Function<TEvent extends IEvent>(EventObserver<TEvent> hook)
-
Registers an observer for a specific event type.
final
-
$eventStream
→ ValueStream<TEvent> Function<TEvent extends IEvent>()
-
Gets the stream of events for a specific event type.
final
-
$globalEventObserver
→ void Function<TEvent extends IEvent>(EventObserver<IEvent> hook)
-
Registers a global observer that receives all events.
final
-
$lastEmitted
→ Option<TEvent> Function<TEvent extends IEvent>()
-
Gets the last emitted event of a specific type.
final
-
$queryHandler
→ void Function<TActionType extends IAction<TResultType>, TResultType>(IActionHandler<TActionType, TResultType> handlerFactory())
-
Registers a query handler factory for a specific IQuery.
final
-
$registerAggregatorBehaviour
→ void Function<TActionType extends IAction<TResultType>, TResultType>(Future<TResultType> behaviour(TActionType action, Future<TResultType> next(TActionType newAction)))
-
Register a pipeline behaviour.
final
-
$registerCommandBehaviour
→ void Function<TActionType extends IAction<TResultType>, TResultType>(Future<TResultType> behaviour(TActionType action, Future<TResultType> next(TActionType newAction)))
-
Register a pipeline behaviour.
final
-
$registerEventBehaviour
→ void Function<TActionType extends IAction<TResultType>, TResultType>(Future<TResultType> behaviour(TActionType action, Future<TResultType> next(TActionType newAction)))
-
Register a pipeline behaviour.
final
-
$registerGenericAggregatorBehaviour
→ void Function(Future behaviour(IAggregator action, Future next(IAggregator newAction)))
-
Register a pipeline behaviour.
final
-
$registerGenericCommandBehaviour
→ void Function(Future behaviour(ICommand action, Future next(ICommand newAction)))
-
Register a pipeline behaviour.
final
-
$registerGenericEventBehaviour
→ void Function(Future<void> behaviour(IEvent action, Future<void> next(IEvent newAction)))
-
Register a pipeline behaviour.
final
-
$registerGenericQueryBehaviour
→ void Function(Future behaviour(IQuery action, Future next(IQuery newAction)))
-
Register a pipeline behaviour.
final
-
$registerQueryBehaviour
→ void Function<TActionType extends IAction<TResultType>, TResultType>(Future<TResultType> behaviour(TActionType action, Future<TResultType> next(TActionType newAction)))
-
Register a pipeline behaviour.
final
-
$request
→ Future<TResult> Function<TResult>(IQuery<TResult> query)
-
Requests a query to its registered handler and returns the result.
final