()
| 209 | // until maxDuration. Detach when the stream closes so it can't fire afterward. |
| 210 | if (signal) { |
| 211 | const onStreamAbort = () => { |
| 212 | const reason = signal.reason instanceof Error ? signal.reason : new Error('Aborted') |
| 213 | stream.destroy(reason) |
| 214 | nodeStream.destroy(reason) |
| 215 | bb.destroy() |
| 216 | } |
| 217 | if (signal.aborted) onStreamAbort() |
| 218 | else { |
| 219 | signal.addEventListener('abort', onStreamAbort, { once: true }) |
no test coverage detected