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