(state, err)
| 8854 | } |
| 8855 | __name(releaseUpgradeStream, "releaseUpgradeStream"); |
| 8856 | function failUpgradeStream(state, err) { |
| 8857 | if (state == null) { |
| 8858 | return; |
| 8859 | } |
| 8860 | const { request } = state; |
| 8861 | if (state.responseReceived || request.aborted || request.completed) { |
| 8862 | return; |
| 8863 | } |
| 8864 | releaseUpgradeStream(state.stream); |
| 8865 | state.abort(err, true); |
| 8866 | } |
| 8867 | __name(failUpgradeStream, "failUpgradeStream"); |
| 8868 | function onUpgradeStreamError() { |
| 8869 | const state = this[kRequestStreamState]; |
no test coverage detected