()
| 2 | |
| 3 | // When using multiple `.readable()`/`.writable()`/`.duplex()`, `final` and `destroy` should wait for other streams |
| 4 | export const initializeConcurrentStreams = () => ({ |
| 5 | readableDestroy: new WeakMap(), |
| 6 | writableFinal: new WeakMap(), |
| 7 | writableDestroy: new WeakMap(), |
| 8 | }); |
| 9 | |
| 10 | // Each file descriptor + `waitName` has its own array of promises. |
| 11 | // Each promise is a single `.readable()`/`.writable()`/`.duplex()` call. |
no outgoing calls
no test coverage detected