(chunks: Uint8Array[], size: number)
| 85 | } |
| 86 | |
| 87 | function concatChunks(chunks: Uint8Array[], size: number) { |
| 88 | if (chunks[0].length === size) { |
| 89 | return chunks.shift(); |
| 90 | } |
| 91 | const buffer = new Uint8Array(size); |
| 92 | let j = 0; |
| 93 | for (let i = 0; i < size; i++) { |
| 94 | buffer[i] = chunks[0][j++]; |
| 95 | if (j === chunks[0].length) { |
| 96 | chunks.shift(); |
| 97 | j = 0; |
| 98 | } |
| 99 | } |
| 100 | if (chunks.length && j < chunks[0].length) { |
| 101 | chunks[0] = chunks[0].slice(j); |
| 102 | } |
| 103 | return buffer; |
| 104 | } |
| 105 | |
| 106 | const enum State { |
| 107 | READ_HEADER, |