onCommandProcessed method

  1. @override
Future<void> onCommandProcessed(
  1. Command command,
  2. List<Event> events
)

Called after a command has been successfully processed Override to perform post-command processing actions

Implementation

@override
Future<void> onCommandProcessed(Command command, List<Event> events) async {
  await super.onCommandProcessed(command, events);

  // Send events back to sender if running in actor system
  final sender = _capturedSenders[command.commandId];
  if (sender != null) {
    sender.tell(ChannelCommandResult(
      commandId: command.commandId,
      events: events,
      success: true,
    ));
    _capturedSenders.remove(command.commandId);
  }
}