| 66 | |
| 67 | // Async consumer iterator throw() |
| 68 | async function testAsyncIteratorThrow() { |
| 69 | const shared = share(from('throw-test')); |
| 70 | const consumer = shared.pull(); |
| 71 | const iter = consumer[Symbol.asyncIterator](); |
| 72 | const first = await iter.next(); |
| 73 | assert.strictEqual(first.done, false); |
| 74 | const result = await iter.throw(new Error('test-throw')); |
| 75 | assert.strictEqual(result.done, true); |
| 76 | assert.strictEqual(shared.consumerCount, 0); |
| 77 | } |
| 78 | |
| 79 | // Sync consumer iterator throw() |
| 80 | async function testSyncIteratorThrow() { |