Function startCompressedServer

test/fetch.compression.test.ts:43–68

(
  encoding: SupportedEncoding,
  statusCode: SupportedStatus,
  options: { chunked?: boolean } = {},
)

}

async function startCompressedServer(
  encoding: SupportedEncoding,
  statusCode: SupportedStatus,
  options: { chunked?: boolean } = {},
): Promise<string> {
  const body = compress(encoding, Buffer.from(JSON.stringify(payload)));
  return startServer((_req, res) => {
    const headers: Record<string, string> = {
      'content-encoding': encoding,
      'content-type': 'application/json',
    };
    if (!options.chunked) {
      headers['content-length'] = String(body.length);
    }
    res.writeHead(statusCode, headers);

    if (options.chunked) {
      // Force chunked transfer-encoding by emitting in two writes without content-length.
      const mid = Math.max(1, Math.floor(body.length / 2));
      res.write(body.subarray(0, mid));
      res.end(body.subarray(mid));
    } else {
      res.end(body);
    }
  });
}

describe('fetchWithProxy compressed responses', () => {
  beforeEach(() => {