Function messageQueue

packages/hosts/mcp/src/stdio-integration.test.ts:81–100

(transport: StdioClientTransport)

);

const messageQueue = (transport: StdioClientTransport) => {
  const messages: Array<JSONRPCMessage> = [];
  const waiters: Array<(message: JSONRPCMessage) => void> = [];

  transport.onmessage = (message) => {
    const waiter = waiters.shift();
    if (waiter) {
      waiter(message);
    } else {
      messages.push(message);
    }
  };

  return {
    next: (): Promise<JSONRPCMessage> => {
      const message = messages.shift();
      return message ? Promise.resolve(message) : new Promise((resolve) => waiters.push(resolve));
    },
  };
};

describe("MCP stdio integration", () => {
  // The regression: a client that opens with an unsupported probe used to get