Set proper stream factory in AbstractUnifiedTest

mongodb · Jul 16, 2021 · c3c0a2c · c3c0a2c
1 parent 411d5dc
commit c3c0a2c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/driver-async/src/test/functional/com/mongodb/async/client/AbstractUnifiedTest.java b/driver-async/src/test/functional/com/mongodb/async/client/AbstractUnifiedTest.java
@@ -62,6 +62,7 @@
 
 import static com.mongodb.ClusterFixture.getMultiMongosConnectionString;
 import static com.mongodb.async.client.Fixture.getConnectionString;
+import static com.mongodb.async.client.Fixture.getStreamFactoryFactory;
 import static com.mongodb.async.client.Fixture.isSharded;
 import static com.mongodb.client.CommandMonitoringTestHelper.assertEventsEquality;
 import static com.mongodb.client.CommandMonitoringTestHelper.getExpectedEvents;
@@ -164,6 +165,7 @@ public void apply(final SocketSettings.Builder builder) {
                         builder.readTimeout(5, TimeUnit.SECONDS);
                     }
                 })
+                .streamFactoryFactory(getStreamFactoryFactory())
                 .retryWrites(clientOptions.getBoolean("retryWrites", BsonBoolean.FALSE).getValue())
                 .writeConcern(getWriteConcern(clientOptions))
                 .readConcern(getReadConcern(clientOptions))