onCommandProcessed method

@override Future<void> onCommandProcessed(Command command, 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) {
    // Send the list of events as response wrapped in LocalMessage
    sender.tell(LocalMessage(payload: events));
    // Clean up captured sender
    _capturedSenders.remove(command.commandId);
  }
}