(stream)
| 233 | } |
| 234 | |
| 235 | function isClosed(stream) { |
| 236 | if (!isNodeStream(stream)) { |
| 237 | return null; |
| 238 | } |
| 239 | |
| 240 | if (typeof stream.closed === 'boolean') { |
| 241 | return stream.closed; |
| 242 | } |
| 243 | |
| 244 | const wState = stream._writableState; |
| 245 | const rState = stream._readableState; |
| 246 | |
| 247 | if ( |
| 248 | typeof wState?.closed === 'boolean' || |
| 249 | typeof rState?.closed === 'boolean' |
| 250 | ) { |
| 251 | return wState?.closed || rState?.closed; |
| 252 | } |
| 253 | |
| 254 | if (typeof stream._closed === 'boolean' && isOutgoingMessage(stream)) { |
| 255 | return stream._closed; |
| 256 | } |
| 257 | |
| 258 | return null; |
| 259 | } |
| 260 | |
| 261 | function isOutgoingMessage(stream) { |
| 262 | return ( |
no test coverage detected
searching dependent graphs…