Function onMessage

src/server/routes/proxy/responses.websocket.test.ts:212–220

(payload: WebSocket.RawData)

      reject(new Error(`Timed out waiting for ${count} websocket messages`));
    }, timeoutMs);
    const onMessage = (payload: WebSocket.RawData) => {
      messages.push(JSON.parse(String(payload)));
      if (messages.length >= count) {
        clearTimeout(timeout);
        socket.off('message', onMessage);
        socket.off('error', onError);
        resolve(messages);
      }
    };
    const onError = (error: Error) => {
      clearTimeout(timeout);
      socket.off('message', onMessage);