| 47 | } |
| 48 | |
| 49 | async function testShareConsumerCount() { |
| 50 | const shared = share(from('data')); |
| 51 | |
| 52 | assert.strictEqual(shared.consumerCount, 0); |
| 53 | |
| 54 | const c1 = shared.pull(); |
| 55 | assert.strictEqual(shared.consumerCount, 1); |
| 56 | |
| 57 | const c2 = shared.pull(); |
| 58 | assert.strictEqual(shared.consumerCount, 2); |
| 59 | |
| 60 | // Cancel detaches all consumers |
| 61 | shared.cancel(); |
| 62 | assert.strictEqual(shared.consumerCount, 0); |
| 63 | |
| 64 | // Both should complete immediately |
| 65 | const [data1, data2] = await Promise.all([ |
| 66 | text(c1), |
| 67 | text(c2), |
| 68 | ]); |
| 69 | assert.strictEqual(data1, ''); |
| 70 | assert.strictEqual(data2, ''); |
| 71 | } |
| 72 | |
| 73 | async function testShareCancel() { |
| 74 | const shared = share(from('data')); |