(stream, state)
| 8900 | } |
| 8901 | __name(onUpgradeResponse, "onUpgradeResponse"); |
| 8902 | function setupUpgradeStream(stream, state) { |
| 8903 | const { request, headersTimeout, session } = state; |
| 8904 | stream[kHTTP2Stream] = true; |
| 8905 | stream[kHTTP2Session] = session; |
| 8906 | stream[kRequestStreamState] = state; |
| 8907 | state.stream = stream; |
| 8908 | bindRequestToStream(request, stream, releaseUpgradeStream); |
| 8909 | stream.once("response", onUpgradeResponse); |
| 8910 | stream.on("error", onUpgradeStreamError); |
| 8911 | stream.once("end", onUpgradeStreamEnd); |
| 8912 | stream.on("timeout", onUpgradeStreamTimeout); |
| 8913 | stream.once("close", onUpgradeStreamClose); |
| 8914 | clearHttp2IdleTimeout(session); |
| 8915 | ++session[kOpenStreams]; |
| 8916 | stream.setTimeout(headersTimeout); |
| 8917 | } |
| 8918 | __name(setupUpgradeStream, "setupUpgradeStream"); |
| 8919 | function writeH2(client, request) { |
| 8920 | const headersTimeout = request.headersTimeout ?? client[kHeadersTimeout]; |
no test coverage detected