Function call

test/proxyClientsE2E.test.js:77–86

({ path: reqPath = '/v1/messages', headers, body })

  srv.actualPort = port;

  const call = ({ path: reqPath = '/v1/messages', headers, body }) => new Promise((resolve, reject) => {
    const req = http.request({ host: '127.0.0.1', port, path: reqPath, method: 'POST',
      headers: { 'content-type': 'application/json', authorization: 'Bearer aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa', 'x-api-key': 'sk-client', ...headers } }, (res) => {
      const chunks = [];
      res.on('data', (d) => chunks.push(d));
      res.on('end', () => resolve({ status: res.statusCode, bytes: Buffer.concat(chunks) }));
    });
    req.on('error', reject);
    req.end(JSON.stringify(body));
  });

  // Each test issues a non-stream + a stream call; the streamed row emits only once its SSE body is drained,
  // so wait for the expected count (not just the first line) before asserting.