@@ -291,7 +291,7 @@ class Client extends DispatcherBase {
291
291
this [ kMaxRequests ] = maxRequestsPerClient
292
292
this [ kClosedResolve ] = null
293
293
this [ kMaxResponseSize ] = maxResponseSize > - 1 ? maxResponseSize : - 1
294
- this [ kHTTPConnVersion ] = 'h1'
294
+ this [ kHTTPConnVersion ] = null
295
295
296
296
// HTTP/2
297
297
this [ kHTTP2Session ] = null
@@ -1177,9 +1177,9 @@ async function connect (client) {
1177
1177
assert ( socket )
1178
1178
1179
1179
if ( socket . alpnProtocol === 'h2' ) {
1180
- await onHTTP2Connect ( client , socket )
1180
+ await connectH2 ( client , socket )
1181
1181
} else {
1182
- await onHTTP1Connect ( client , socket )
1182
+ await connectH1 ( client , socket )
1183
1183
}
1184
1184
1185
1185
addListener ( socket , 'close' , onSocketClose )
@@ -2271,7 +2271,9 @@ function errorRequest (client, request, err) {
2271
2271
}
2272
2272
}
2273
2273
2274
- async function onHTTP1Connect ( client , socket ) {
2274
+ async function connectH1 ( client , socket ) {
2275
+ client [ kHTTPConnVersion ] = 'h1'
2276
+
2275
2277
if ( ! llhttpInstance ) {
2276
2278
llhttpInstance = await llhttpPromise
2277
2279
llhttpPromise = null
@@ -2332,7 +2334,9 @@ async function onHTTP1Connect (client, socket) {
2332
2334
} )
2333
2335
}
2334
2336
2335
- async function onHTTP2Connect ( client , socket ) {
2337
+ async function connectH2 ( client , socket ) {
2338
+ client [ kHTTPConnVersion ] = 'h2'
2339
+
2336
2340
if ( ! h2ExperimentalWarned ) {
2337
2341
h2ExperimentalWarned = true
2338
2342
process . emitWarning ( 'H2 support is experimental, expect them to change at any time.' , {
@@ -2345,7 +2349,6 @@ async function onHTTP2Connect (client, socket) {
2345
2349
peerMaxConcurrentStreams : client [ kHTTP2SessionState ] . maxConcurrentStreams
2346
2350
} )
2347
2351
2348
- client [ kHTTPConnVersion ] = 'h2'
2349
2352
session [ kClient ] = client
2350
2353
session [ kSocket ] = socket
2351
2354
session . on ( 'error' , onHttp2SessionError )
0 commit comments