runCore method

  1. @override
Future<AgentResponse> runCore(
  1. Iterable<ChatMessage> messages, {
  2. AgentSession? session,
  3. AgentRunOptions? options,
  4. CancellationToken? cancellationToken,
})
override

Core implementation of the agent invocation logic.

Implementation

@override
Future<AgentResponse> runCore(
  Iterable<ChatMessage> messages, {
  AgentSession? session,
  AgentRunOptions? options,
  CancellationToken? cancellationToken,
}) async {
  final response = await _otelClient.getResponse(
    messages: messages,
    options: ForwardedOptions(options, session, Activity.current),
    cancellationToken: cancellationToken,
  );
  final raw = response.rawRepresentation;
  return raw is AgentResponse ? raw : AgentResponse(response: response);
}