expect(error).toBeInstanceOf(Error);

expect((error as Error).message).toMatch(/LLM idle timeout/);

expect(onIdleTimeout).toHaveBeenCalledTimes(1);

const [timeoutError] = onIdleTimeout.mock.calls[0] ?? [];

const [timeoutError] = onIdleTimeout.mock.calls.at(0) ?? [];

expect(timeoutError).toBeInstanceOf(Error);

expect((timeoutError as Error).message).toMatch(/LLM idle timeout/);

});

await handleToolExecutionStart(ctx, evt);

expect(warn).toHaveBeenCalledTimes(1);

expect(String(warn.mock.calls[0]?.[0] ?? "")).toContain("read tool called without path");

expect(String(warn.mock.calls.at(0)?.[0] ?? "")).toContain("read tool called without path");

});

it("awaits onBlockReplyFlush before continuing tool start processing", async () => {

await Promise.resolve();

expect(onToolResult).toHaveBeenCalledTimes(1);

const payload = onToolResult.mock.calls[0][0];

const payload = onToolResult.mock.calls.at(0)?.[0];

expect(payload.text).toContain("🖼️");

expect(payload.text).toContain("Canvas");

expect(payload.text).toContain("/tmp/a2ui.jsonl");

emitAssistantTextDeltaAndEnd({ emit, text });

expect(onBlockReply).toHaveBeenCalledTimes(3);

expect(onBlockReply.mock.calls[1][0].text).toBe("~~~sh\nline1\nline2\n~~~");

expect(onBlockReply.mock.calls.at(1)?.[0].text).toBe("~~~sh\nline1\nline2\n~~~");

});

});

await flushBlockReplyCallbacks();

expect(onBlockReply).toHaveBeenCalledTimes(1);

expect(onBlockReply.mock.calls[0][0].text).toBe("Final answer");

expect(onBlockReply.mock.calls.at(0)?.[0].text).toBe("Final answer");

const streamTexts = onReasoningStream.mock.calls

.map((call) => call[0]?.text)