MCPcopy Index your code
hub / github.com/nodejs/node / releaseRequestStream

Function releaseRequestStream

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

Source from the content-addressed store, hash-verified

9125 }
9126 __name(removeRequestStreamListeners, "removeRequestStreamListeners");
9127 function releaseRequestStream(stream) {
9128 if (stream == null) {
9129 return;
9130 }
9131 const state = stream[kRequestStreamState];
9132 if (state == null) {
9133 return;
9134 }
9135 const { request } = state;
9136 if (request[kRequestStream] === stream) {
9137 detachRequestFromStream(request);
9138 }
9139 removeRequestStreamListeners(stream);
9140 if (!stream.destroyed && !stream.closed) {
9141 stream.once("error", noop);
9142 }
9143 }
9144 __name(releaseRequestStream, "releaseRequestStream");
9145 function onData(chunk) {
9146 const stream = this;

Callers 2

onRequestStreamCloseFunction · 0.70
onResponseFunction · 0.70

Calls 3

detachRequestFromStreamFunction · 0.70
onceMethod · 0.45

Tested by

no test coverage detected