Lines Matching refs:stream
21 return promise_rejects_exactly(t, error2, writer.closed, 'the writable stream must be errored with error2')
42 // Trying to abort a stream that is erroring will give the writable's error
43 return promise_rejects_exactly(t, error2, rs.pipeTo(ws), 'pipeTo must reject with the writable stream\'s error').then(() => {
48 promise_rejects_exactly(t, error1, rs.getReader().closed, 'the readable stream must be errored with error1'),
49 promise_rejects_exactly(t, error2, ws.getWriter().closed, 'the writable stream must be errored with error2')
53 }, 'Piping from an errored readable stream to an erroring writable stream');
63 .then(ws => promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the readable stream\'s error'))
67 return promise_rejects_exactly(t, error1, rs.getReader().closed, 'the readable stream must be errored with error1');
69 }, 'Piping from an errored readable stream to an errored writable stream');
84 'pipeTo must reject with the readable stream\'s error')
90 promise_rejects_exactly(t, error1, rs.getReader().closed, 'the readable stream must be errored with error1'),
91 promise_rejects_exactly(t, error2, ws.getWriter().closed, 'the writable stream must be errored with error2')
95 }, 'Piping from an errored readable stream to an erroring writable stream; preventAbort = true');
105 'pipeTo must reject with the readable stream\'s error'))
109 return promise_rejects_exactly(t, error1, rs.getReader().closed, 'the readable stream must be errored with error1');
112 }, 'Piping from an errored readable stream to an errored writable stream; preventAbort = true');
125 return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the readable stream\'s error').then(() => {
130 promise_rejects_exactly(t, error1, rs.getReader().closed, 'the readable stream must be errored with error1'),
138 }, 'Piping from an errored readable stream to a closing writable stream');
152 return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the readable stream\'s error').then(() => {
157 promise_rejects_exactly(t, error1, rs.getReader().closed, 'the readable stream must be errored with error1'),
164 }, 'Piping from an errored readable stream to a closed writable stream');
178 return promise_rejects_exactly(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the writable stream\'s error').then(() => {
184 promise_rejects_exactly(t, error1, ws.getWriter().closed, 'the writable stream must be errored with error1')
188 }, 'Piping from a closed readable stream to an erroring writable stream');
197 .then(ws => promise_rejects_exactly(t, error2, rs.pipeTo(ws), 'pipeTo must reject with the writable stream\'s error'))
204 }, 'Piping from a closed readable stream to an errored writable stream');
227 }, 'Piping from a closed readable stream to a closed writable stream');