Function createCompressionStream

src/utils/compression.ts:149–171

(
  format?: CompressionFormat,
)

}

export const createCompressionStream = (
  format?: CompressionFormat,
): Transform => {
  if (!format) {
    return new PassThrough()
  }

  switch (format) {
    case CompressionFormat.GZIP:
      return createGzip()
    case CompressionFormat.XZ: {
      const lzmaNative = getLzmaNative()
      const { preset, threads } = getXzCompressionOptions(cpus().length)

      return lzmaNative.createCompressor({
        preset,
        threads,
      })
    }
    default:
      throw new Error(`Unsupported compression format: ${String(format)}`)
  }
}

export const createDecompressionStream = (
  format?: CompressionFormat,