}) as DispatchReplyWithBufferedBlockDispatcher;

}

function requireFirstMockCall<T>(mock: { mock: { calls: T[][] } }, label: string): T[] {

const call = mock.mock.calls.at(0);

if (!call) {

throw new Error(`expected ${label} call`);

}

return call;

}

function createDurableSendResult(messageIds: string[]) {

return {

status: "sent",

expect(events).toEqual(["record", "dispatch"]);

expect(deliver).not.toHaveBeenCalled();

expect(onFinalize).toHaveBeenCalledTimes(1);

const [finalized] = onFinalize.mock.calls[0] as unknown as [unknown];

const [finalized] = requireFirstMockCall(onFinalize, "finalize");

const finalizedResult = finalizeResult(finalized);

expect(finalizedResult.admission).toEqual({

kind: "observeOnly",

}

expect(hasFinalChannelTurnDispatch(result.dispatchResult)).toBe(false);

expect(onFinalize).toHaveBeenCalledTimes(1);

const [finalized] = onFinalize.mock.calls[0] as unknown as [unknown];

const [finalized] = requireFirstMockCall(onFinalize, "finalize");

const finalizedResult = finalizeResult(finalized);

expect(finalizedResult.admission).toEqual({

kind: "observeOnly",

).rejects.toThrow(dispatchError);

expect(onFinalize).toHaveBeenCalledTimes(1);

const [finalized] = onFinalize.mock.calls[0] as unknown as [unknown];

const [finalized] = requireFirstMockCall(onFinalize, "finalize");

const finalizedResult = finalizeResult(finalized);

expect(finalizedResult.admission).toEqual({ kind: "dispatch" });

expect(finalizedResult.dispatched).toBe(false);