Function transformBytes

packages/shell/src/extras.ts:458–472

(
  bytes: Uint8Array,
  stream: CompressionStream | DecompressionStream
)

}

async function transformBytes(
  bytes: Uint8Array,
  stream: CompressionStream | DecompressionStream
): Promise<Uint8Array> {
  const input = new Blob([new Uint8Array(bytes)]).stream();
  const transformed = input.pipeThrough(stream);
  const chunks: Uint8Array[] = [];
  const reader = transformed.getReader();
  for (;;) {
    const { done, value } = await reader.read();
    if (done) break;
    chunks.push(value);
  }
  return concatBytes(chunks);
}

function concatBytes(chunks: Uint8Array[]): Uint8Array {
  const total = chunks.reduce((sum, chunk) => sum + chunk.byteLength, 0);