@@ -53,7 +53,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
53
53
given :
54
54
def connection = new InternalStreamConnectionFactory (ClusterConnectionMode . SINGLE ,
55
55
new AsynchronousSocketChannelStreamFactory (openSocketSettings, getSslSettings()), getCredentialWithCache(), null , null ,
56
- [], LoggerSettings . builder(). build(), null , getServerApi())
56
+ [], LoggerSettings . builder(). build(), null , getServerApi(), null )
57
57
.create(new ServerId (new ClusterId (), new ServerAddress (new InetSocketAddress (' 192.168.255.255' , 27017 ))))
58
58
59
59
when :
@@ -68,7 +68,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
68
68
given :
69
69
def connection = new InternalStreamConnectionFactory (ClusterConnectionMode . SINGLE ,
70
70
new AsynchronousSocketChannelStreamFactory (readSocketSettings, getSslSettings()), getCredentialWithCache(), null , null ,
71
- [], LoggerSettings . builder(). build(), null , getServerApi()). create(new ServerId (new ClusterId (), getPrimary()))
71
+ [], LoggerSettings . builder(). build(), null , getServerApi(), null ). create(new ServerId (new ClusterId (), getPrimary()))
72
72
connection. open()
73
73
74
74
getCollectionHelper(). insertDocuments(new BsonDocument (' _id' , new BsonInt32 (1 )))
@@ -89,7 +89,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
89
89
given :
90
90
def connection = new InternalStreamConnectionFactory (ClusterConnectionMode . SINGLE ,
91
91
new NettyStreamFactory (openSocketSettings, getSslSettings()), getCredentialWithCache(), null , null ,
92
- [], LoggerSettings . builder(). build(), null , getServerApi()). create(new ServerId (new ClusterId (),
92
+ [], LoggerSettings . builder(). build(), null , getServerApi(), null ). create(new ServerId (new ClusterId (),
93
93
new ServerAddress (new InetSocketAddress (' 192.168.255.255' , 27017 ))))
94
94
95
95
when :
@@ -104,7 +104,7 @@ class AsyncStreamTimeoutsSpecification extends OperationFunctionalSpecification
104
104
given :
105
105
def connection = new InternalStreamConnectionFactory (ClusterConnectionMode . SINGLE ,
106
106
new NettyStreamFactory (readSocketSettings, getSslSettings()), getCredentialWithCache(), null , null ,
107
- [], LoggerSettings . builder(). build(), null , getServerApi()). create(new ServerId (new ClusterId (), getPrimary()))
107
+ [], LoggerSettings . builder(). build(), null , getServerApi(), null ). create(new ServerId (new ClusterId (), getPrimary()))
108
108
connection. open()
109
109
110
110
getCollectionHelper(). insertDocuments(new BsonDocument (' _id' , new BsonInt32 (1 )))
0 commit comments