@@ -15,6 +15,7 @@ const MIN_SUPPORTED_SERVER_VERSION = WIRE_CONSTANTS.MIN_SUPPORTED_SERVER_VERSION
15
15
let AUTH_PROVIDERS ;
16
16
17
17
function connect ( options , callback ) {
18
+ const ConnectionType = options && options . connectionType ? options . connectionType : Connection ;
18
19
if ( AUTH_PROVIDERS == null ) {
19
20
AUTH_PROVIDERS = defaultAuthProviders ( options . bson ) ;
20
21
}
@@ -26,7 +27,7 @@ function connect(options, callback) {
26
27
return ;
27
28
}
28
29
29
- performInitialHandshake ( new Connection ( socket , options ) , options , callback ) ;
30
+ performInitialHandshake ( new ConnectionType ( socket , options ) , options , callback ) ;
30
31
} ) ;
31
32
32
33
return ;
@@ -40,13 +41,13 @@ function connect(options, callback) {
40
41
return ;
41
42
}
42
43
43
- performInitialHandshake ( new Connection ( ipv4Socket , options ) , options , callback ) ;
44
+ performInitialHandshake ( new ConnectionType ( ipv4Socket , options ) , options , callback ) ;
44
45
} ) ;
45
46
46
47
return ;
47
48
}
48
49
49
- performInitialHandshake ( new Connection ( ipv6Socket , options ) , options , callback ) ;
50
+ performInitialHandshake ( new ConnectionType ( ipv6Socket , options ) , options , callback ) ;
50
51
} ) ;
51
52
}
52
53
0 commit comments