Lines Matching refs:rs
89 const rs = new ReadableStream(); constant
92 const result = rs.pipeThrough({ readable, writable });
108 const rs = new ReadableStream(); constant
112 () => rs.pipeThrough({
128 const rs = new ReadableStream({ constant
134 assert_throws_js(TypeError, () => rs.pipeThrough({
150 const rs = new ReadableStream({ constant
155 readable: rs,
161 () => ReadableStream.prototype.pipeThrough.call(rs, throwingWritable, {}),
171 () => ReadableStream.prototype.pipeThrough.call(rs, throwingReadable, {}),
179 const rs = new ReadableStream(); constant
180 … assert_throws_js(TypeError, () => rs.pipeThrough(uninterestingReadableWritablePair(), { signal }),
186 const rs = new ReadableStream(); constant
189 rs.pipeThrough(uninterestingReadableWritablePair(), { signal });
193 const rs = new ReadableStream(); constant
194 rs.getReader();
195 assert_throws_js(TypeError, () => rs.pipeThrough(uninterestingReadableWritablePair()),
200 const rs = new ReadableStream(); constant
204 assert_throws_js(TypeError, () => rs.pipeThrough({writable, readable}),
209 const rs = new ReadableStream(); constant
213 assert_equals(rs.pipeThrough({ writable, readable }), readable,
218 const rs = recordingReadableStream(); constant
225 rs.pipeThrough({ writable, readable }, { preventCancel: true });
227 assert_array_equals(rs.events, ['pull'], 'cancel should not have been called');
232 const rs = new ReadableStream({ constant
239 rs.pipeThrough({ writable, readable }, { preventClose: true });
246 const rs = new ReadableStream({ constant
253 rs.pipeThrough({ writable, readable }, { preventAbort: true });
260 const rs = new ReadableStream(); constant
263 assert_throws_js(TypeError, () => rs.pipeThrough({readable, writable}, {
271 const rs = new ReadableStream(); constant
274 rs.pipeThrough({readable, writable}, null);
278 const rs = new ReadableStream(); constant
281 rs.pipeThrough({readable, writable}, {signal:undefined});
286 const rs = new ReadableStream();
290 rs.pipeThrough(pair, options)