mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-10-20 00:15:55 +00:00
chore[protocol]: deep clone log
This commit is contained in:
1 parent
32fbeae1d9
commit
7c516da9d1
2 files changed
+2
No files matched your search
@@ -21,6 +21,7 @@ class ByteBuffer implements IByteBuffer {
|
|||||||
writeInt(length);
|
writeInt(length);
|
||||||
setWriteOffset(currentWriteIndex);
|
setWriteOffset(currentWriteIndex);
|
||||||
} else {
|
} else {
|
||||||
|
// sublist of Int8List is deep clone
|
||||||
var retainedByteBuf =
|
var retainedByteBuf =
|
||||||
buffer.sublist(currentWriteIndex - length, currentWriteIndex);
|
buffer.sublist(currentWriteIndex - length, currentWriteIndex);
|
||||||
setWriteOffset(beforeWriteIndex);
|
setWriteOffset(beforeWriteIndex);
|
||||||
|
|||||||
@@ -24,6 +24,7 @@ func adjustPadding(predictionLength: int, beforeWriteIndex: int) -> void:
|
|||||||
writeInt(length)
|
writeInt(length)
|
||||||
setWriteOffset(currentWriteIndex)
|
setWriteOffset(currentWriteIndex)
|
||||||
else:
|
else:
|
||||||
|
# get_partial_data of StreamPeerBuffer is deep clone
|
||||||
buffer.seek(currentWriteIndex - length)
|
buffer.seek(currentWriteIndex - length)
|
||||||
var retainedByteBuf = buffer.get_partial_data(length)[1]
|
var retainedByteBuf = buffer.get_partial_data(length)[1]
|
||||||
setWriteOffset(beforeWriteIndex)
|
setWriteOffset(beforeWriteIndex)
|
||||||
|
|||||||
Reference in new issue
Block a user