(chunks, size)
| 417 | }, 0); |
| 418 | } |
| 419 | function concatChunks(chunks, size) { |
| 420 | if (chunks[0].length === size) { |
| 421 | return chunks.shift(); |
| 422 | } |
| 423 | var buffer = new Uint8Array(size); |
| 424 | var j = 0; |
| 425 | for (var i = 0; i < size; i++) { |
| 426 | buffer[i] = chunks[0][j++]; |
| 427 | if (j === chunks[0].length) { |
| 428 | chunks.shift(); |
| 429 | j = 0; |
| 430 | } |
| 431 | } |
| 432 | if (chunks.length && j < chunks[0].length) { |
| 433 | chunks[0] = chunks[0].slice(j); |
| 434 | } |
| 435 | return buffer; |
| 436 | } |
| 437 | function createPacketDecoderStream(maxPayload, binaryType) { |
| 438 | if (!TEXT_DECODER) { |
| 439 | TEXT_DECODER = new TextDecoder(); |
no outgoing calls
no test coverage detected