runCoreStreaming method

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

Core implementation of the agent streaming invocation logic.

Implementation

@override
Stream<AgentResponseUpdate> runCoreStreaming(
  Iterable<ChatMessage> messages, {
  AgentSession? session,
  AgentRunOptions? options,
  CancellationToken? cancellationToken,
}) {
  return innerAgent.runCoreStreaming(
    messages,
    session: session,
    options: agentRunOptionsWithFunctionMiddleware(options),
    cancellationToken: cancellationToken,
  );
}