lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

pb

Browse Source
This commit is contained in:
redkale
2024-10-02 09:29:04 +08:00
parent 4e71f8009a
commit 67aa3c0609
3 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/redkale/convert/pb/ProtobufArrayEncoder.java
View File

@@ -32,17 +32,17 @@ public class ProtobufArrayEncoder<T> extends ArrayEncoder<ProtobufWriter, T>
if (value == null || value.length < 1) {
return;
}
Encodeable itemEncoder = this.componentEncoder;
ProtobufEncodeable itemEncoder = (ProtobufEncodeable) this.componentEncoder;
out.writeArrayB(value.length, itemEncoder, value);
for (T item : value) {
out.writeField(member);
if (item == null) {
out.writeLength(0);
} else if (componentSimpled) {
itemEncoder.convertTo(out, item);
itemEncoder.convertTo(out, member, item);
} else {
ProtobufWriter tmp = out.pollChild();
itemEncoder.convertTo(tmp, item);
itemEncoder.convertTo(tmp, member, item);
out.offerChild(tmp);
}
}

4
src/main/java/org/redkale/convert/pb/ProtobufCollectionEncoder.java
View File

@@ -39,10 +39,10 @@ public class ProtobufCollectionEncoder<T> extends CollectionEncoder<ProtobufWrit
if (item == null) {
out.writeLength(0);
} else if (componentSimpled) {
itemEncoder.convertTo(out, item);
itemEncoder.convertTo(out, member, item);
} else {
ProtobufWriter tmp = out.pollChild();
itemEncoder.convertTo(tmp, item);
itemEncoder.convertTo(tmp, member, item);
out.offerChild(tmp);
}
}

4
src/main/java/org/redkale/convert/pb/ProtobufStreamEncoder.java
View File

@@ -39,10 +39,10 @@ public class ProtobufStreamEncoder<T> extends StreamEncoder<ProtobufWriter, T>
if (item == null) {
out.writeLength(0);
} else if (componentSimpled) {
itemEncoder.convertTo(out, item);
itemEncoder.convertTo(out, member, item);
} else {
ProtobufWriter tmp = out.pollChild();
itemEncoder.convertTo(tmp, item);
itemEncoder.convertTo(tmp, member, item);
out.offerChild(tmp);
}
}