Lines Matching refs:rs
10 const rs = new ReadableStream(); constant
11 const result = rs.tee();
22 const rs = new ReadableStream({ constant
30 const branch = rs.tee();
59 const rs = new ReadableStream({ constant
65 const branch = rs.tee();
80 const rs = new ReadableStream({ constant
90 const branches = rs.tee();
115 const rs = new ReadableStream({ constant
123 const branches = rs.tee();
141 const rs = new ReadableStream({ constant
149 const branches = rs.tee();
200 const rs = new ReadableStream({ constant
206 const branches = rs.tee();
220 const rs = new ReadableStream({ constant
226 const branches = rs.tee();
244 const rs = new ReadableStream({ constant
250 const [reader1, reader2] = rs.tee().map(branch => branch.getReader());
274 const rs = new ReadableStream({ constant
280 const [reader1, reader2] = rs.tee().map(branch => branch.getReader());
294 const rs = new ReadableStream({}); constant
296 const [branch1, branch2] = rs.tee();
309 const rs = new ReadableStream({ constant
315 const [branch1, branch2] = rs.tee();
355 const rs = recordingReadableStream({}, { highWaterMark: 0 }); constant
359 rs.tee();
361 assert_array_equals(rs.events, ['pull'], 'pull should only be called once');
368 const rs = recordingReadableStream({ constant
374 const [reader1, reader2] = rs.tee().map(branch => branch.getReader());
377 assert_array_equals(rs.events, ['pull', 'pull'], 'pull should be called twice');
384 const rs = recordingReadableStream({}, { highWaterMark: 0 }); constant
387 rs.controller.error(theError);
389 const [reader1, reader2] = rs.tee().map(branch => branch.getReader());
392 assert_array_equals(rs.events, [], 'pull should not be called');
405 const rs = recordingReadableStream({}, { highWaterMark: 0 }); constant
408 const [reader1, reader2] = rs.tee().map(branch => branch.getReader());
411 assert_array_equals(rs.events, ['pull'], 'pull should be called once');
413 rs.controller.enqueue('a');
418 assert_array_equals(rs.events, ['pull', 'pull'], 'pull should be called twice');
420 rs.controller.error(theError);
427 assert_array_equals(rs.events, ['pull', 'pull'], 'pull should be called twice');
435 const rs = recordingReadableStream({}, { highWaterMark: 0 }); constant
438 const [reader1, reader2] = rs.tee().map(branch => branch.getReader());
441 assert_array_equals(rs.events, ['pull'], 'pull should be called once');
443 rs.controller.enqueue('a');
447 assert_array_equals(rs.events, ['pull', 'pull'], 'pull should be called twice');
449 rs.controller.error(theError);
456 assert_array_equals(rs.events, ['pull', 'pull'], 'pull should be called twice');
463 const rs = recordingReadableStream(); constant
465 const [reader1, reader2] = rs.tee().map(branch => branch.getReader());
470 rs.controller.enqueue('a');
471 rs.controller.close();