Function compressResponseStream

src/helper.ts:199–207

(event: H3Event, value: unknown, method?: StreamCompression)

 * @returns { Promise<Response> }
 */
export async function compressResponseStream(event: H3Event, value: unknown, method?: StreamCompression): Promise<Response> {
  const response = await ensureToResponse()(value, event)
  const compressionMethod = method ?? getStreamCompression(event)

  if (!compressionMethod || !response.body || response.headers.has('Content-Encoding'))
    return response

  return cloneResponse(response, response.body.pipeThrough(new CompressionStream(compressionMethod)), compressionMethod)
}