Function processMessage

test/shared/protocol.test.ts:5184–5195

()

            // This should not throw
            const processMessage = async () => {
                const msg = await taskMessageQueue.dequeue(task.taskId);
                if (msg && msg.type === 'response') {
                    const testProtocol = protocol as unknown as TestProtocol;
                    const responseMessage = msg.message as JSONRPCResultResponse;
                    const requestId = responseMessage.id as RequestId;
                    const resolver = testProtocol._requestResolvers.get(requestId);
                    if (!resolver) {
                        protocol.onerror?.(new Error(`Response handler missing for request ${requestId}`));
                    }
                }
            };

            await expect(processMessage()).resolves.not.toThrow();
        });