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

Function releaseUpgradeStream

deps/undici/undici.js:8838–8854  ·  view source on GitHub ↗
(stream)

Source from the content-addressed store, hash-verified

8836 }
8837 __name(removeUpgradeStreamListeners, "removeUpgradeStreamListeners");
8838 function releaseUpgradeStream(stream) {
8839 if (stream == null) {
8840 return;
8841 }
8842 const state = stream[kRequestStreamState];
8843 if (state == null) {
8844 return;
8845 }
8846 const { request } = state;
8847 if (request[kRequestStream] === stream) {
8848 detachRequestFromStream(request);
8849 }
8850 removeUpgradeStreamListeners(stream);
8851 if (!stream.destroyed && !stream.closed) {
8852 stream.once("error", noop);
8853 }
8854 }
8855 __name(releaseUpgradeStream, "releaseUpgradeStream");
8856 function failUpgradeStream(state, err) {
8857 if (state == null) {

Callers 1

failUpgradeStreamFunction · 0.70

Calls 3

detachRequestFromStreamFunction · 0.70
onceMethod · 0.45

Tested by

no test coverage detected