onAny<TCommand extends Object> method

void onAny<TCommand extends Object>(AggregateIdResolver<TCommand, TId> toId, AggregateCommandHandler<TCommand, TEvent, TValue, TId, TState, TAggregate> action)

Register an asynchronous handler for a command, which is expected to use an a new (if id does not exist) or an existing aggregate instance. Use parameter toId to get the AggregateId from give command. Use parameter action to performed actions on the aggregate, given the aggregate instance and the command

• Type parameter TCommand - Command type

Implementation

void onAny<TCommand extends Object>(
    AggregateIdResolver<TCommand, TId> toId,
    AggregateCommandHandler<TCommand, TEvent, TValue, TId, TState, TAggregate>
        action) {
  assert(!isFrozen, 'Aggregate handlers has been frozen');

  _handlers.putIfAbsent(
    typeOf<TCommand>(),
    () => RegisteredAggregateCommandHandler<TCommand, TEvent, TValue, TId,
        TState, TAggregate>(
      ExpectedState.any,
      action,
    ),
  );

  _resolvers.putIfAbsent(
    typeOf<TCommand>(),
    () => (command) => toId(command as TCommand),
  );
}