(err)
| 55161 | }; |
| 55162 | const onAbort = function() { |
| 55163 | if (finished) { |
| 55164 | return; |
| 55165 | } |
| 55166 | const err = new RequestAbortedError(); |
| 55167 | queueMicrotask(() => onFinished(err)); |
| 55168 | }; |
| 55169 | const onFinished = function(err) { |
| 55170 | if (finished) { |
| 55171 | return; |
| 55172 | } |
| 55173 | finished = true; |
| 55174 | assert2(socket.destroyed || socket[kWriting] && client[kRunning] <= 1); |
| 55175 | socket.off("drain", onDrain).off("error", onFinished); |
| 55176 | body.removeListener("data", onData).removeListener("end", onFinished).removeListener("error", onFinished).removeListener("close", onAbort); |
| 55177 | if (!err) { |
| 55178 | try { |
| 55179 | writer.end(); |
| 55180 | } catch (er2) { |
| 55181 | err = er2; |
| 55182 | } |
| 55183 | } |
| 55184 | writer.destroy(err); |
| 55185 | if (err && (err.code !== "UND_ERR_INFO" || err.message !== "reset")) { |
| 55186 | util4.destroy(body, err); |
| 55187 | } else { |
no test coverage detected
searching dependent graphs…