Lines Matching refs:rs
10 const rs = new ReadableStream({ type: 'bytes' }); constant
11 const result = rs.tee();
22 const rs = new ReadableStream({ constant
31 const [branch1, branch2] = rs.tee();
69 const rs = new ReadableStream({ constant
79 const [branch1, branch2] = rs.tee();
101 const rs = new ReadableStream({ constant
112 const [branch1, branch2] = rs.tee();
134 const rs = new ReadableStream({ constant
145 const [branch1, branch2] = rs.tee();
173 const rs = new ReadableStream({ constant
182 const [branch1, branch2] = rs.tee();
195 const rs = new ReadableStream({ constant
204 const [branch1, branch2] = rs.tee();
222 const rs = new ReadableStream({ constant
229 const [branch1, branch2] = rs.tee();
249 const rs = new ReadableStream({ constant
256 const [branch1, branch2] = rs.tee();
274 const rs = new ReadableStream({ constant
281 const [branch1, branch2] = rs.tee();
299 const rs = new ReadableStream({ constant
306 const [branch1, branch2] = rs.tee();
324 const rs = new ReadableStream({ constant
331 const [branch1, branch2] = rs.tee();
358 const rs = new ReadableStream({ constant
365 const [branch1, branch2] = rs.tee();
381 const rs = recordingReadableStream({ type: 'bytes' }); constant
384 rs.tee();
387 assert_array_equals(rs.events, [], 'pull should not be called');
393 const rs = recordingReadableStream({ constant
400 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
405 assert_array_equals(rs.events, ['pull'], 'pull should be called once');
411 const rs = recordingReadableStream({ type: 'bytes' }); constant
414 rs.controller.error(theError);
416 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
419 assert_array_equals(rs.events, [], 'pull should not be called');
431 const rs = recordingReadableStream({ type: 'bytes' }); constant
434 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
437 assert_array_equals(rs.events, [], 'pull should not be called');
443 assert_array_equals(rs.events, ['pull'], 'pull should be called once');
445 rs.controller.error(theError);
454 assert_array_equals(rs.events, ['pull'], 'pull should be called once');
461 const rs = recordingReadableStream({ type: 'bytes' }); constant
464 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
467 assert_array_equals(rs.events, [], 'pull should not be called');
473 assert_array_equals(rs.events, ['pull'], 'pull should be called once');
475 rs.controller.error(theError);
485 assert_array_equals(rs.events, ['pull'], 'pull should be called once');
491 const rs = recordingReadableStream({ type: 'bytes' }); constant
493 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
514 const rs = new ReadableStream({ constant
521 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
548 const rs = recordingReadableStream({ constant
555 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
563 const byobRequest1 = rs.controller.byobRequest;
573 const byobRequest2 = rs.controller.byobRequest;
579 const byobRequest3 = rs.controller.byobRequest;
595 const rs = recordingReadableStream({ constant
602 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
610 const byobRequest1 = rs.controller.byobRequest;
620 const byobRequest2 = rs.controller.byobRequest;
626 const byobRequest3 = rs.controller.byobRequest;
638 const rs = recordingReadableStream({ type: 'bytes' }); constant
640 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
648 …assert_typed_array_equals(rs.controller.byobRequest.view, new Uint8Array([0x11]), 'first byobReque…
656 …assert_typed_array_equals(rs.controller.byobRequest.view, new Uint8Array([0x11]), 'second byobRequ…
659 rs.controller.byobRequest.view[0] = 0x33;
660 rs.controller.byobRequest.respond(1);
671 const rs = recordingReadableStream({ type: 'bytes' }); constant
673 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
681 …assert_typed_array_equals(rs.controller.byobRequest.view, new Uint8Array([0x11]), 'first byobReque…
689 …assert_typed_array_equals(rs.controller.byobRequest.view, new Uint8Array([0x11]), 'second byobRequ…
692 rs.controller.byobRequest.view[0] = 0x33;
693 rs.controller.byobRequest.respond(1);
706 const rs = new ReadableStream({ constant
715 const [branch1, _] = rs.tee();
739 const rs = new ReadableStream({ constant
748 const [branch1, _] = rs.tee();
770 const rs = recordingReadableStream({ constant
773 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
783 const byobRequest = rs.controller.byobRequest;
800 const rs = recordingReadableStream({ type: 'bytes' }); constant
801 const [branch1, branch2] = rs.tee();
811 assert_equals(rs.controller.byobRequest, null, 'first BYOB request');
814 rs.controller.close();
829 const rs = recordingReadableStream({ type: 'bytes' }); constant
830 const [branch1, branch2] = rs.tee();
840 assert_equals(rs.controller.byobRequest, null, 'first BYOB request');
843 rs.controller.close();
858 const rs = recordingReadableStream({ type: 'bytes' }); constant
859 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
867 const byobRequest = rs.controller.byobRequest;
871 rs.controller.close();
887 const rs = recordingReadableStream({ type: 'bytes' }); constant
889 const [reader1, reader2] = rs.tee().map(branch => branch.getReader());
894 rs.controller.enqueue(new Uint8Array([0x11]));
895 rs.controller.close();
911 const rs = recordingReadableStream({ type: 'bytes' }); constant
913 const [reader1, reader2] = rs.tee().map(branch => branch.getReader({ mode: 'byob' }));
918 rs.controller.byobRequest.view[0] = 0x11;
919 rs.controller.byobRequest.respond(1);
920 rs.controller.close();