()
| 143 | |
| 144 | // Channel fail propagation |
| 145 | async function testChannelFail() { |
| 146 | const [a, b] = duplex(); |
| 147 | a.writer.fail(new Error('channel failed')); |
| 148 | await assert.rejects(async () => { |
| 149 | // eslint-disable-next-line no-unused-vars |
| 150 | for await (const _ of b.readable) { /* consume */ } |
| 151 | }, { message: 'channel failed' }); |
| 152 | await b.close(); |
| 153 | } |
| 154 | |
| 155 | // Abort signal affects both channels |
| 156 | async function testAbortSignalBothChannels() { |
no test coverage detected
searching dependent graphs…