Notify bolt handler of all errors in routed connection

neo4j · Nov 20, 2024 · 27037c1 · 27037c1
1 parent c85bbf5
commit 27037c1
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/driver/src/main/java/org/neo4j/driver/internal/bolt/routedimpl/RoutedBoltConnection.java b/driver/src/main/java/org/neo4j/driver/internal/bolt/routedimpl/RoutedBoltConnection.java
@@ -183,14 +183,9 @@ public CompletionStage<BoltConnection> clear() {
     @Override
     public CompletionStage<Void> flush(ResponseHandler handler) {
         return delegate.flush(new ResponseHandler() {
-            private Throwable error;
-
             @Override
             public void onError(Throwable throwable) {
-                if (error == null) {
-                    error = handledError(throwable);
-                    handler.onError(error);
-                }
+                handler.onError(handledError(throwable));
             }
 
             @Override