()
| 197 | } |
| 198 | |
| 199 | async function testShareAlreadyAborted() { |
| 200 | const shared = share(from('data'), { signal: AbortSignal.abort() }); |
| 201 | const consumer = shared.pull(); |
| 202 | |
| 203 | await assert.rejects(async () => { |
| 204 | // eslint-disable-next-line no-unused-vars |
| 205 | for await (const _ of consumer) { |
| 206 | assert.fail('Should not reach here'); |
| 207 | } |
| 208 | }, { name: 'AbortError' }); |
| 209 | } |
| 210 | |
| 211 | // ============================================================================= |
| 212 | // Source error propagation |