| 70 | |
| 71 | // Regression test: merge() with sync iterable sources |
| 72 | async function testMergeSyncSources() { |
| 73 | const s1 = fromSync('abc'); |
| 74 | const s2 = fromSync('def'); |
| 75 | const result = await text(merge(s1, s2)); |
| 76 | // Both sources should be fully consumed; order may vary |
| 77 | assert.strictEqual(result.length, 6); |
| 78 | for (const ch of 'abcdef') { |
| 79 | assert.ok(result.includes(ch), `missing '${ch}' in '${result}'`); |
| 80 | } |
| 81 | } |
| 82 | |
| 83 | // ============================================================================= |
| 84 | // Merge error propagation |