(source, transforms, signal)
| 130 | } |
| 131 | |
| 132 | function canUseSyncIterablePipeToFastPath(source, transforms, signal) { |
| 133 | if (signal !== undefined || |
| 134 | transforms.length !== 0 || |
| 135 | isPrimitiveChunk(source) || |
| 136 | ArrayIsArray(source) || |
| 137 | source?.[kValidatedSource] || |
| 138 | !isSyncIterable(source) || |
| 139 | isAsyncIterable(source)) { |
| 140 | return false; |
| 141 | } |
| 142 | |
| 143 | // Preserve from()'s top-level protocol precedence for custom iterables. |
| 144 | return typeof source[toAsyncStreamable] !== 'function' && |
| 145 | typeof source[toStreamable] !== 'function'; |
| 146 | } |
| 147 | |
| 148 | // ============================================================================= |
| 149 | // Transform Output Flattening |
no test coverage detected
searching dependent graphs…