Function toBuffer

test/unit/utils/compression.spec.ts:30–38

(stream: NodeJS.ReadableStream)

}

const toBuffer = async (stream: NodeJS.ReadableStream): Promise<Buffer> => {
  const chunks: Buffer[] = []

  for await (const chunk of stream as AsyncIterable<Buffer | string>) {
    chunks.push(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk))
  }

  return Buffer.concat(chunks)
}

const expectStreamToFail = async (stream: NodeJS.ReadableStream): Promise<void> => {
  try {