(headers, _flags)
| 8884 | } |
| 8885 | __name(onUpgradeStreamTimeout, "onUpgradeStreamTimeout"); |
| 8886 | function onUpgradeResponse(headers, _flags) { |
| 8887 | const stream = this; |
| 8888 | const state = stream[kRequestStreamState]; |
| 8889 | const { request } = state; |
| 8890 | state.responseReceived = true; |
| 8891 | const statusCode = headers[HTTP2_HEADER_STATUS]; |
| 8892 | delete headers[HTTP2_HEADER_STATUS]; |
| 8893 | request.onRequestUpgrade(statusCode, headers, stream); |
| 8894 | if (request.aborted || request.completed) { |
| 8895 | return; |
| 8896 | } |
| 8897 | removeUpgradeStreamListeners(stream); |
| 8898 | detachRequestFromStream(request); |
| 8899 | state.finalizeRequest(); |
| 8900 | } |
| 8901 | __name(onUpgradeResponse, "onUpgradeResponse"); |
| 8902 | function setupUpgradeStream(stream, state) { |
| 8903 | const { request, headersTimeout, session } = state; |
nothing calls this directly
no test coverage detected