(subprocess, error)
| 31 | |
| 32 | // When `readable` or `writable` aborts/errors, awaits the subprocess, for the reason mentioned above |
| 33 | export const waitForSubprocess = async (subprocess, error) => { |
| 34 | await subprocess; |
| 35 | if (error) { |
| 36 | throw error; |
| 37 | } |
| 38 | }; |
| 39 | |
| 40 | export const destroyOtherStream = (stream, isOpen, error) => { |
| 41 | if (error && !isStreamAbort(error)) { |
no outgoing calls
no test coverage detected