Skip to content

Commit cf32512

Browse files
authored
Slight tweak
1 parent 16a3a20 commit cf32512

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

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

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -196,8 +196,7 @@ public void close() {
196196

197197
@Override
198198
public void run() {
199-
ServerDescription unknownConnectingServerDescription = unknownConnectingServerDescription(serverId, null);
200-
ServerDescription currentServerDescription = unknownConnectingServerDescription;
199+
ServerDescription currentServerDescription = unknownConnectingServerDescription(serverId, null);
201200
try {
202201
while (!isClosed) {
203202
ServerDescription previousServerDescription = currentServerDescription;
@@ -217,7 +216,7 @@ public void run() {
217216
continue;
218217
}
219218

220-
// For POLL mode, if we just established initial connection, do an immediate heartbeat
219+
// When not streaming, if we just established initial connection, do an immediate heartbeat
221220
if (!shouldStreamResponses && connection != null && !connection.isClosed()
222221
&& currentServerDescription.equals(connection.getInitialServerDescription())) {
223222
continue;

0 commit comments

Comments
 (0)