MCPcopy Create free account
hub / github.com/nodejs/node / setupUpgradeStream

Function setupUpgradeStream

deps/undici/undici.js:8902–8917  ·  view source on GitHub ↗
(stream, state)

Source from the content-addressed store, hash-verified

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];

Callers 1

writeH2Function · 0.70

Calls 5

bindRequestToStreamFunction · 0.70
clearHttp2IdleTimeoutFunction · 0.70
onceMethod · 0.45
onMethod · 0.45
setTimeoutMethod · 0.45

Tested by

no test coverage detected