We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fa2fe92 commit a9ac556Copy full SHA for a9ac556
driver/src/main/java/org/neo4j/driver/internal/cursor/RxResultCursorImpl.java
@@ -169,7 +169,11 @@ public void onError(Throwable throwable) {
169
170
@Override
171
public void onIgnored() {
172
- onError(new ClientException("The message has been ignored by the server possibly for a previous failure"));
+ var throwable = termSupplier.get();
173
+ if (throwable == null) {
174
+ throwable = new ClientException("A message has been ignored during result streaming.");
175
+ }
176
+ onError(throwable);
177
}
178
179
0 commit comments