Lines Matching refs:stream
154 const stream = new ReadableStream({
158 const reader = stream.getReader();
165 const stream = new ReadableStream({
169 const reader = stream.getReader({ mode: 'byob' });
176 const stream = new ReadableStream({
184 const reader = stream.getReader();
187 assert_throws_js(TypeError, () => stream.getReader(), 'getReader() must throw');
189 }, 'ReadableStream with byte source: Test that closing a stream does not release a reader automatically');
192 const stream = new ReadableStream({
200 const reader = stream.getReader({ mode: 'byob' });
203 assert_throws_js(TypeError, () => stream.getReader({ mode: 'byob' }), 'getReader() must throw');
205 }, 'ReadableStream with byte source: Test that closing a stream does not release a BYOB reader automatically');
208 const stream = new ReadableStream({
216 const reader = stream.getReader();
219 assert_throws_js(TypeError, () => stream.getReader(), 'getReader() must throw');
221 }, 'ReadableStream with byte source: Test that erroring a stream does not release a reader automatically');
224 const stream = new ReadableStream({
232 const reader = stream.getReader({ mode: 'byob' });
235 assert_throws_js(TypeError, () => stream.getReader({ mode: 'byob' }), 'getReader() must throw');
237 }, 'ReadableStream with byte source: Test that erroring a stream does not release a BYOB reader automatically');
240 const stream = new ReadableStream({
244 const reader = stream.getReader();
251 const stream = new ReadableStream({
255 const reader = stream.getReader({ mode: 'byob' });
264 const stream = new ReadableStream({
273 stream.getReader();
275 assert_equals(pullCount, 0, 'No pull as start() just finished and is not yet reflected to the state of the stream');
285 const stream = new ReadableStream({
294 const reader = stream.getReader();
297 assert_equals(pullCount, 0, 'No pull as start() just finished and is not yet reflected to the state of the stream');
319 const stream = new ReadableStream({
348 const reader = stream.getReader();
352 assert_equals(pullCount, 0, 'No pull() as start() just finished and is not yet reflected to the state of the stream');
403 const stream = new ReadableStream({
432 const reader = stream.getReader();
451 const byobReader = stream.getReader({ mode: 'byob' });
477 const stream = new ReadableStream({
486 const reader = stream.getReader();
489 assert_equals(pullCount, 0, 'No pull as start() just finished and is not yet reflected to the state of the stream');
503 const stream = new ReadableStream({
525 const reader = stream.getReader();
546 const stream = new ReadableStream({
553 const reader = stream.getReader();
578 const stream = new ReadableStream({
585 const reader = stream.getReader();
599 const stream = new ReadableStream({
610 const byobReader = stream.getReader({ mode: 'byob' });
624 const reader = stream.getReader();
642 const stream = new ReadableStream({
650 const reader = stream.getReader();
670 const stream = new ReadableStream({
679 const reader = stream.getReader();
699 const stream = new ReadableStream({
710 const reader = stream.getReader();
726 const stream = new ReadableStream({
745 const reader = stream.getReader();
779 const stream = new ReadableStream({
797 const reader = stream.getReader();
803 assert_equals(pullCount, 0, 'No pull as start() just finished and is not yet reflected to the state of the stream');
829 const stream = new ReadableStream({
849 const reader = stream.getReader({ mode: 'byob' });
869 const stream = new ReadableStream({
889 const reader = stream.getReader({ mode: 'byob' });
907 const stream = new ReadableStream({
925 const reader = stream.getReader({ mode: 'byob' });
941 const stream = new ReadableStream({
961 const reader = stream.getReader({ mode: 'byob' });
996 const stream = new ReadableStream({
1006 const reader = stream.getReader({ mode: 'byob' });
1024 const stream = new ReadableStream({
1039 const reader = stream.getReader();
1054 const stream = new ReadableStream({
1069 const reader = stream.getReader({ mode: 'byob' });
1086 const stream = new ReadableStream({
1103 const reader = stream.getReader({ mode: 'byob' });
1126 const stream = new ReadableStream({
1145 const reader = stream.getReader({ mode: 'byob' });
1168 const stream = new ReadableStream({
1182 const reader = stream.getReader({ mode: 'byob' });
1205 const stream = new ReadableStream({
1225 const reader = stream.getReader({ mode: 'byob' });
1243 const stream = new ReadableStream({
1255 const reader = stream.getReader({ mode: 'byob' });
1272 const stream = new ReadableStream({
1285 const reader = stream.getReader({ mode: 'byob' });
1312 const stream = new ReadableStream({
1334 const reader = stream.getReader({ mode: 'byob' });
1361 const stream = new ReadableStream({
1389 const reader = stream.getReader({ mode: 'byob' });
1434 const stream = new ReadableStream({
1445 const reader = stream.getReader({ mode: 'byob' });
1450 }, 'ReadableStream with byte source: read(view) with Uint16Array on close()-d stream with 1 byte enqueue()-d must ' +
1456 const stream = new ReadableStream({
1468 const reader = stream.getReader({ mode: 'byob' });
1476 }, 'ReadableStream with byte source: A stream must be errored if close()-d before fulfilling read(view) with ' +
1489 // Enqueue a chunk so that the stream doesn't get closed. This is to check duplicate close() calls are rejected
1490 // even if the stream has not yet entered the closed state.
1508 // Enqueue a chunk so that the stream doesn't get closed. This is to check enqueue() after close() is rejected
1509 // even if the stream has not yet entered the closed state.
1522 const stream = new ReadableStream({
1538 const reader = stream.getReader({ mode: 'byob' });
1571 const stream = new ReadableStream({
1594 const reader = stream.getReader({ mode: 'byob' });
1625 const stream = new ReadableStream({
1647 const reader = stream.getReader({ mode: 'byob' });
1677 const stream = new ReadableStream({
1689 const reader = stream.getReader();
1736 const stream = new ReadableStream({
1744 const reader = stream.getReader({ mode: 'byob' });
1773 const stream = new ReadableStream({
1781 const reader = stream.getReader({ mode: 'byob' });
1809 const stream = new ReadableStream({
1817 const reader = stream.getReader({ mode: 'byob' });
1844 const stream = new ReadableStream({
1851 const reader = stream.getReader({ mode: 'byob' });
1858 const stream = new ReadableStream({
1862 const reader = stream.getReader({ mode: 'byob' });
1868 const stream = new ReadableStream({
1872 const reader = stream.getReader({ mode: 'byob' });
1880 const stream = new ReadableStream({
1888 const reader = stream.getReader();
1891 }, 'ReadableStream with byte source: read() on an errored stream');
1896 const stream = new ReadableStream({
1903 const reader = stream.getReader();
1913 const stream = new ReadableStream({
1921 const reader = stream.getReader({ mode: 'byob' });
1924 }, 'ReadableStream with byte source: read(view) on an errored stream');
1929 const stream = new ReadableStream({
1936 const reader = stream.getReader({ mode: 'byob' });
1951 const stream = new ReadableStream({
1962 const reader = stream.getReader();
1967 }, 'ReadableStream with byte source: Throwing in pull function must error the stream');
1972 const stream = new ReadableStream({
1981 const reader = stream.getReader();
1986 }, 'ReadableStream with byte source: Throwing in pull in response to read() must be ignored if the stream is ' +
1994 const stream = new ReadableStream({
2002 const reader = stream.getReader({ mode: 'byob' });
2007 }, 'ReadableStream with byte source: Throwing in pull in response to read(view) function must error the stream');
2012 const stream = new ReadableStream({
2021 const reader = stream.getReader({ mode: 'byob' });
2026 }, 'ReadableStream with byte source: Throwing in pull in response to read(view) must be ignored if the stream is ' +
2179 const stream = new ReadableStream({ type: 'bytes' });
2180 new ReadableStreamBYOBReader(stream);
2190 const stream = new ReadableStream({ type: 'bytes' });
2191 stream.getReader();
2192 assert_throws_js(TypeError, () => new ReadableStreamBYOBReader(stream), 'constructor must throw');
2197 const stream = new ReadableStream();
2198 assert_throws_js(TypeError, () => new ReadableStreamBYOBReader(stream), 'constructor must throw');
2225 const stream = new ReadableStream({
2234 const reader = stream.getReader({ mode: 'byob' });
2248 const stream = new ReadableStream({
2258 const reader = stream.getReader({ mode: 'byob' });
2276 const stream = new ReadableStream({
2286 const reader = stream.getReader({ mode: 'byob' });
2316 const stream = new ReadableStream({
2326 const reader = stream.getReader({ mode: 'byob' });
2882 const stream = new ReadableStream({
2892 const reader = stream.getReader();