Skip to content

Commit 817a5c5

Browse files
committed
Reuse OperatioContext.
1 parent 3736c17 commit 817a5c5

2 files changed

Lines changed: 4 additions & 3 deletions

File tree

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,6 @@
4040
import java.util.concurrent.atomic.AtomicLong;
4141

4242
import static com.mongodb.internal.VisibleForTesting.AccessModifier.PACKAGE;
43-
import static com.mongodb.internal.VisibleForTesting.AccessModifier.PRIVATE;
4443
import static java.util.stream.Collectors.toList;
4544

4645
/**

driver-core/src/test/functional/com/mongodb/internal/operation/CommandBatchCursorFunctionalTest.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import com.mongodb.client.model.OperationTest;
2828
import com.mongodb.internal.binding.ConnectionSource;
2929
import com.mongodb.internal.connection.Connection;
30+
import com.mongodb.internal.connection.OperationContext;
3031
import com.mongodb.internal.validator.NoOpFieldNameValidator;
3132
import org.bson.BsonArray;
3233
import org.bson.BsonBoolean;
@@ -86,8 +87,9 @@ void setup() {
8687
.collect(Collectors.toList());
8788
getCollectionHelper().insertDocuments(documents);
8889

89-
connectionSource = getBinding().getWriteConnectionSource(ClusterFixture.createOperationContext());
90-
connection = connectionSource.getConnection(ClusterFixture.createOperationContext());
90+
OperationContext operationContext = ClusterFixture.createOperationContext();
91+
connectionSource = getBinding().getWriteConnectionSource(operationContext);
92+
connection = connectionSource.getConnection(operationContext);
9193
}
9294

9395
@AfterEach

0 commit comments

Comments
 (0)