Skip to content

Commit 34c0dc0

Browse files
committed
Updated SocketStreamHelperSpecification
1 parent bbc2d10 commit 34c0dc0

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

driver-core/src/test/functional/com/mongodb/internal/connection/SocketStreamHelperSpecification.groovy

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,8 @@ import javax.net.ssl.SSLSocketFactory
3131
import java.lang.reflect.Method
3232

3333
import static com.mongodb.ClusterFixture.OPERATION_CONTEXT
34+
import static com.mongodb.ClusterFixture.TIMEOUT_SETTINGS
35+
import static com.mongodb.ClusterFixture.createOperationContext
3436
import static com.mongodb.ClusterFixture.getPrimary
3537
import static com.mongodb.internal.connection.ServerAddressHelper.getSocketAddresses
3638
import static java.util.concurrent.TimeUnit.MILLISECONDS
@@ -45,8 +47,10 @@ class SocketStreamHelperSpecification extends Specification {
4547
.readTimeout(10, SECONDS)
4648
.build()
4749
50+
def operationContext = createOperationContext(TIMEOUT_SETTINGS.withReadTimeoutMS(socketSettings.getReadTimeout(MILLISECONDS)))
51+
4852
when:
49-
SocketStreamHelper.initialize(OPERATION_CONTEXT, socket, getSocketAddresses(getPrimary(), new DefaultInetAddressResolver()).get(0),
53+
SocketStreamHelper.initialize(operationContext, socket, getSocketAddresses(getPrimary(), new DefaultInetAddressResolver()).get(0),
5054
socketSettings, SslSettings.builder().build())
5155
5256
then:

0 commit comments

Comments
 (0)