handle method

  1. @override
Future<void> handle(
  1. Object? message,
  2. WorkflowContext context, {
  3. CancellationToken? cancellationToken,
})
override

Handles an inbound message.

Implementation

@override
Future<void> handle(
  Object? message,
  WorkflowContext context, {
  CancellationToken? cancellationToken,
}) async {
  for (final chatMessage in ChatProtocol.toChatMessages(message)) {
    await context.sendMessage(
      chatMessage,
      targetExecutorId: targetExecutorId,
      cancellationToken: cancellationToken,
    );
  }
}