andreacavalli
/
CavalliumDBEngine-Server
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Bugfix

This commit is contained in:
Andrea Cavalli 2022-04-01 01:31:26 +02:00
parent f93c70f2b7
commit 59eca54f11
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/main/java/it/cavallium/dbengine/database/remote/QuicRPCServer.java
View File

@ -194,17 +194,22 @@ public class QuicRPCServer {
return localDb.getAllocator().copyOf(QuicUtils.toArrayNoCopy(newValue.value()));
}
}, singletonUpdateInit.updateReturnMode())
.map(result -> new BinaryOptional(result != null ? NullableBinary.of(Binary.of(toByteList(result))) : NullableBinary.empty()));
.map(resultSend -> {
if (resultSend != null) {
try (var r = resultSend.receive()) {
return new BinaryOptional(NullableBinary.of(Binary.of(toByteList(r))));
}
}
return new BinaryOptional(NullableBinary.empty());
});
return Flux.merge(update, clientBound.asFlux());
});
}
private static ByteList toByteList(Send<Buffer> prev) {
try (var prevVal = prev.receive()) {
byte[] result = new byte[prevVal.readableBytes()];
prevVal.readBytes(result, 0, result.length);
return ByteList.of(result);
}
private static ByteList toByteList(Buffer prev) {
byte[] result = new byte[prev.readableBytes()];
prev.readBytes(result, 0, result.length);
return ByteList.of(result);
}
private Mono<GeneratedEntityId> handleGetSingleton(GetSingleton getSingleton) {