expect(load).toHaveBeenCalledTimes(1);

});

it("unbinds in-flight wrapped entry when stop() fires between deliverPending and bindPending", async () => {

const deliverGate = { resolve: () => {}, promise: Promise.resolve() };

const deliverPromise = new Promise<void>((resolve) => {

deliverGate.resolve = resolve;

it("unbinds in-flight wrapped entry when stop() fires between bindPending and activeEntries.set", async () => {

const bindGate = { resolve: () => {}, promise: Promise.resolve() };

const bindPromise = new Promise<void>((resolve) => {

bindGate.resolve = resolve;

});

deliverGate.promise = deliverPromise;

const deliverPending = vi.fn(async () => {

await deliverPromise;

return { messageId: "in-flight" };

bindGate.promise = bindPromise;

const deliverPending = vi.fn().mockResolvedValue({ messageId: "in-flight" });

const bindPending = vi.fn(async () => {

await bindPromise;

return { bindingId: "bound-in-flight" };

});

const bindPending = vi.fn().mockResolvedValue({ bindingId: "bound-in-flight" });

const unbindPending = vi.fn();

const runtime = await createTestApprovalHandler(

const request = makeExecApprovalRequest("exec:in-flight");

const inflight = approvalRuntime.handleRequested(request);

// microtasks 흘려 deliverPending 완료 + bindPending await 진입.

await new Promise((r) => setTimeout(r, 0));

await new Promise((r) => setTimeout(r, 0));

// stop() while deliverPending is parked — onStopped flips the closure flag.

// stop() — onStopped 가 stopped flag set. bindPending 은 park.

await approvalRuntime.stop();

deliverGate.resolve();

bindGate.resolve();

await inflight;

expect(unbindPending).toHaveBeenCalledTimes(1);

const unbind = firstCallArg(unbindPending) as

| { entry?: unknown; binding?: unknown; request?: unknown }

| undefined;

expect(unbind?.entry).toEqual({ messageId: "in-flight" });

expect(unbind?.binding).toEqual({ bindingId: "bound-in-flight" });

expect(unbind?.request).toBe(request);

expect(bindPending).not.toHaveBeenCalled();

});

});