it("is safe to call before connect()", () => {

const manager = buildManager();

expect(() => manager.close()).not.toThrow();

expect(manager.close()).toBeUndefined();

expect(manager.connectionState).toBe("closed");

});

});

blockReplyBreak: "text_end",

});

// This should not throw even without onBlockReplyFlush

expect(() => {

// Missing onBlockReplyFlush should still accept streaming events.

expect(

handler?.({

type: "tool_execution_start",

toolName: "bash",

toolCallId: "tool-no-flush",

args: { command: "echo test" },

});

}).not.toThrow();

}),

).toBeUndefined();

});

});

});

it("swallows only ignorable stop errors", () => {

expect(() => {

expect(

stopTuiSafely(() => {

throw new Error("setRawMode EBADF");

});

}).not.toThrow();

}),

).toBeUndefined();

});

it("rethrows non-ignorable stop errors", () => {