});

expect(supervisor.drainPending(() => "continue")).toBe("continue");

expect(() => supervisor.attachLifecycle(() => {})).not.toThrow();

expect(() => supervisor.detachLifecycle()).not.toThrow();

expect(() => supervisor.dispose()).not.toThrow();

expect(() => supervisor.dispose()).not.toThrow();

supervisor.attachLifecycle(() => {});

supervisor.detachLifecycle();

supervisor.dispose();

supervisor.dispose();

});

it("keeps suppressing late gateway errors after dispose", () => {

supervisor.dispose();

expect(() =>

emitter.emit("error", new Error("Max reconnect attempts (0) reached after close code 1005")),

).not.toThrow();

emitter.emit("error", new Error("Max reconnect attempts (0) reached after close code 1005"));

expect(runtime.error).toHaveBeenCalledWith(

expect.stringContaining("suppressed late gateway reconnect-exhausted error after dispose"),

);

from: "+15553333333",

});

expect(() => processEvent(ctx, event)).not.toThrow();

processEvent(ctx, event);

expect(ctx.activeCalls.size).toBe(0);

});

const promise = runFfprobe(["pipe:0"], { input: Buffer.alloc(1024) });

const stdinError = Object.assign(new Error("write EPIPE"), { code: "EPIPE" });

expect(() => child.stdin?.emit("error", stdinError)).not.toThrow();

child.stdin?.emit("error", stdinError);

execCallback()(null, Buffer.from("ok"), Buffer.alloc(0));

await expect(promise).resolves.toBe("ok");

const promise = runFfprobe(["pipe:0"], { input: Buffer.alloc(1024) });

const stdinError = Object.assign(new Error("write EPIPE"), { code: "EPIPE" });

expect(() => child.stdin?.emit("error", stdinError)).not.toThrow();

child.stdin?.emit("error", stdinError);

const childError = new Error("ffprobe failed");

execCallback()(childError, "", "");