| 2292 | let writeCallbackErr; |
| 2293 | let endCheckCallbackErr; |
| 2294 | const done = () => { |
| 2295 | if (waitingForEndCheck || waitingForWriteCallback) return; |
| 2296 | const err = aggregateTwoErrors(endCheckCallbackErr, writeCallbackErr); |
| 2297 | // writeGeneric does not destroy on error and |
| 2298 | // we cannot enable autoDestroy, |
| 2299 | // so make sure to destroy on error. |
| 2300 | if (err) { |
| 2301 | this.destroy(err); |
| 2302 | } |
| 2303 | cb(err); |
| 2304 | }; |
| 2305 | const writeCallback = (err) => { |
| 2306 | waitingForWriteCallback = false; |
| 2307 | writeCallbackErr = err; |