Skip to content

Commit ddebc59

Browse files
committed
Notify Bolt handler of all errors in routed connection
1 parent c85bbf5 commit ddebc59

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

driver/src/main/java/org/neo4j/driver/internal/bolt/routedimpl/RoutedBoltConnection.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -183,14 +183,9 @@ public CompletionStage<BoltConnection> clear() {
183183
@Override
184184
public CompletionStage<Void> flush(ResponseHandler handler) {
185185
return delegate.flush(new ResponseHandler() {
186-
private Throwable error;
187-
188186
@Override
189187
public void onError(Throwable throwable) {
190-
if (error == null) {
191-
error = handledError(throwable);
192-
handler.onError(error);
193-
}
188+
handler.onError(handledError(throwable));
194189
}
195190

196191
@Override

0 commit comments

Comments
 (0)