bugfix

neo4j · Sep 12, 2024 · a9ac556 · a9ac556
1 parent fa2fe92
commit a9ac556
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/driver/src/main/java/org/neo4j/driver/internal/cursor/RxResultCursorImpl.java b/driver/src/main/java/org/neo4j/driver/internal/cursor/RxResultCursorImpl.java
@@ -169,7 +169,11 @@ public void onError(Throwable throwable) {
 
     @Override
     public void onIgnored() {
-        onError(new ClientException("The message has been ignored by the server possibly for a previous failure"));
+        var throwable = termSupplier.get();
+        if (throwable == null) {
+            throwable = new ClientException("A message has been ignored during result streaming.");
+        }
+        onError(throwable);
     }
 
     @Override