(stream)
| 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; |
no test coverage detected