(obj, strict = false)
| 92 | const kDestroyed = Symbol('kDestroyed') |
| 93 | const kIsReadable = Symbol('kIsReadable') |
| 94 | const isReadableNodeStream = (obj, strict = false) => { |
| 95 | return !!( |
| 96 | ( |
| 97 | obj && |
| 98 | typeof obj.pipe === 'function' && |
| 99 | typeof obj.on === 'function' && |
| 100 | (!strict || (typeof obj.pause === 'function' && typeof obj.resume === 'function')) && |
| 101 | (!obj._writableState || obj._readableState?.readable !== false) && // Duplex |
| 102 | (!obj._writableState || obj._readableState) |
| 103 | ) // Writable has .pipe. |
| 104 | ) |
| 105 | } |
| 106 | const isNodeStream = obj => { |
| 107 | return ( |
| 108 | obj && |
no outgoing calls
no test coverage detected