(stream, strict)
| 120 | return !!(stream.destroyed || stream[kDestroyed] || state?.destroyed) |
| 121 | } |
| 122 | const isReadableFinished = (stream, strict) => { |
| 123 | if (!isReadableNodeStream(stream)) return null |
| 124 | const rState = stream._readableState |
| 125 | if (rState?.errored) return false |
| 126 | if (typeof rState?.endEmitted !== 'boolean') return null |
| 127 | return !!(rState.endEmitted || (strict === false && rState.ended === true && rState.length === 0)) |
| 128 | } |
| 129 | const isReadableStream = stream => { |
| 130 | if (typeof Stream.isReadable === 'function') return Stream.isReadable(stream) |
| 131 | if (stream && stream[kIsReadable] != null) return stream[kIsReadable] |
no test coverage detected