Class StreamingLLM

packages/agent-core/test/loop/streaming.e2e.test.ts:23–36

* A custom LLM that exposes onTextDelta / onThinkDelta / onToolCallDelta / * onTextPart / onThinkPart so each test can decide what the provider emits.

 * onTextPart / onThinkPart so each test can decide what the provider emits.
 */
class StreamingLLM implements LLM {
  readonly systemPrompt = 'streaming system prompt';
  readonly modelName = 'streaming';

  readonly responseProvider: (params: LLMChatParams) => Promise<LLMChatResponse>;

  constructor(provider: (params: LLMChatParams) => Promise<LLMChatResponse>) {
    this.responseProvider = provider;
  }

  async chat(params: LLMChatParams): Promise<LLMChatResponse> {
    return this.responseProvider(params);
  }
}

async function runWithLLM(llm: LLM): Promise<{
  sink: CollectingSink;