Skip to content

Commit eedd983

Browse files
committed
Rebase fix (async API)
1 parent e21e5e5 commit eedd983

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

driver-core/src/main/com/mongodb/internal/connection/InternalStreamConnection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -383,7 +383,7 @@ public <T> void sendAndReceiveAsync(final CommandMessage message, final Decoder<
383383
message, decoder, sessionContext, requestContext, operationContext, c);
384384
beginAsync().<T>thenSupply(c -> {
385385
sendAndReceiveAsyncInternal.getAsync(c);
386-
}).onErrorIf(e -> reauthenticationIsTriggered(e), c -> {
386+
}).onErrorIf(e -> reauthenticationIsTriggered(e), (t, c) -> {
387387
reauthenticateAndRetryAsync(sendAndReceiveAsyncInternal, c);
388388
}).finish(callback);
389389
}

0 commit comments

Comments
 (0)