From 47df47ffe2e80ff6ad43ef62f221beb92468daa3 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Fri, 20 May 2022 10:25:35 +0200
Subject: [PATCH] Update dbengine

---
 .../dbengine/database/server/QuicRPCServer.java       | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/src/main/java/it/cavallium/dbengine/database/server/QuicRPCServer.java b/src/main/java/it/cavallium/dbengine/database/server/QuicRPCServer.java
index eabcc13..638351d 100644
--- a/src/main/java/it/cavallium/dbengine/database/server/QuicRPCServer.java
+++ b/src/main/java/it/cavallium/dbengine/database/server/QuicRPCServer.java
@@ -198,10 +198,13 @@ public class QuicRPCServer {
 							return localDb.getAllocator().copyOf(QuicUtils.toArrayNoCopy(newValue.value()));
 						}
 					}, singletonUpdateInit.updateReturnMode())
-							.map(resultSend -> {
-								if (resultSend != null) {
-									try (var r = resultSend.receive()) {
-										return new BinaryOptional(NullableBinary.of(Binary.of(toByteList(r))));
+							.map(result -> {
+								if (result != null) {
+									try {
+										return new BinaryOptional(NullableBinary.of(Binary.of(toByteList(result))));
+									} catch (Throwable ex) {
+										result.close();
+										throw ex;
 									}
 								}
 								return new BinaryOptional(NullableBinary.empty());