parent
cd6eadd6e0
commit
a291a803fb
|
@ -244,7 +244,7 @@ export default {
|
||||||
if (packet_length === Infinity) break;
|
if (packet_length === Infinity) break;
|
||||||
throw new Error('Unexpected end of packet');
|
throw new Error('Unexpected end of packet');
|
||||||
}
|
}
|
||||||
const chunk = value.subarray(0, packet_length - bytesRead);
|
const chunk = packet_length === Infinity ? value : value.subarray(0, packet_length - bytesRead);
|
||||||
if (writer) await writer.write(chunk);
|
if (writer) await writer.write(chunk);
|
||||||
else packet.push(chunk);
|
else packet.push(chunk);
|
||||||
bytesRead += value.length;
|
bytesRead += value.length;
|
||||||
|
|
Loading…
Reference in New Issue
Block a user