Lines Matching refs:reader

28   let reader = rs.getReader({ mode: { toString() { return 'byob'; } } });
29 assert_true(reader instanceof ReadableStreamBYOBReader, 'must give a BYOB reader');
30 reader.releaseLock();
32 reader = rs.getReader({ mode: { toString: null, valueOf() {return 'byob';} } });
33 assert_true(reader instanceof ReadableStreamBYOBReader, 'must give a BYOB reader');
34 reader.releaseLock();
36 reader = rs.getReader({ mode: 'byob', notmode: 'ignored' });
37 assert_true(reader instanceof ReadableStreamBYOBReader, 'must give a BYOB reader');
158 const reader = stream.getReader();
159 reader.releaseLock();
161 return promise_rejects_js(t, TypeError, reader.closed, 'closed must reject');
169 const reader = stream.getReader({ mode: 'byob' });
170 reader.releaseLock();
172 return promise_rejects_js(t, TypeError, reader.closed, 'closed must reject');
184 const reader = stream.getReader();
186 return reader.closed.then(() => {
189 }, 'ReadableStream with byte source: Test that closing a stream does not release a reader automatically');
200 const reader = stream.getReader({ mode: 'byob' });
202 return reader.closed.then(() => {
205 }, 'ReadableStream with byte source: Test that closing a stream does not release a BYOB reader automatically');
216 const reader = stream.getReader();
218 return promise_rejects_exactly(t, error1, reader.closed, 'closed must reject').then(() => {
221 }, 'ReadableStream with byte source: Test that erroring a stream does not release a reader automatically');
232 const reader = stream.getReader({ mode: 'byob' });
234 return promise_rejects_exactly(t, error1, reader.closed, 'closed must reject').then(() => {
237 }, 'ReadableStream with byte source: Test that erroring a stream does not release a BYOB reader automatically');
244 const reader = stream.getReader();
245 const read = reader.read();
246 reader.releaseLock();
255 const reader = stream.getReader({ mode: 'byob' });
256 const read = reader.read(new Uint8Array(1));
257 reader.releaseLock();
294 const reader = stream.getReader();
295 reader.read();
348 const reader = stream.getReader();
349 const p0 = reader.read();
350 const p1 = reader.read();
432 const reader = stream.getReader();
433 return reader.read().then(result => {
450 reader.releaseLock();
486 const reader = stream.getReader();
487 reader.read(new Uint8Array(8));
525 const reader = stream.getReader();
527 const promise = reader.read();
553 const reader = stream.getReader();
555 const promise = reader.read().then(result => {
585 const reader = stream.getReader();
587 return reader.read().then(result => {
624 const reader = stream.getReader();
626 return reader.read();
650 const reader = stream.getReader();
655 return reader.read().then(result => {
662 return reader.read();
679 const reader = stream.getReader();
681 return reader.read().then(result => {
688 return reader.read();
710 const reader = stream.getReader();
712 return reader.read().then(result => {
745 const reader = stream.getReader();
747 const p0 = reader.read();
748 const p1 = reader.read();
749 const p2 = reader.read();
797 const reader = stream.getReader();
799 const p0 = reader.read();
800 const p1 = reader.read();
801 const p2 = reader.read();
849 const reader = stream.getReader({ mode: 'byob' });
851 return reader.read(new Uint8Array(1)).then(result => {
889 const reader = stream.getReader({ mode: 'byob' });
891 return reader.read(new Uint8Array(1)).then(result => {
925 const reader = stream.getReader({ mode: 'byob' });
927 return reader.read(new Uint8Array(1)).then(() => {
961 const reader = stream.getReader({ mode: 'byob' });
963 return reader.read(new Uint16Array(2)).then(result => {
975 return reader.read(new Uint8Array(1));
1006 const reader = stream.getReader({ mode: 'byob' });
1008 return reader.read(new Uint8Array(16)).then(result => {
1039 const reader = stream.getReader();
1041 return reader.cancel(passedReason).then(result => {
1069 const reader = stream.getReader({ mode: 'byob' });
1071 return reader.cancel(passedReason).then(result => {
1103 const reader = stream.getReader({ mode: 'byob' });
1105 const readPromise = reader.read(new Uint8Array(1)).then(result => {
1110 const cancelPromise = reader.cancel(passedReason).then(result => {
1145 const reader = stream.getReader({ mode: 'byob' });
1147 const promise = reader.read(new Uint16Array(1)).then(result => {
1157 reader.cancel();
1182 const reader = stream.getReader({ mode: 'byob' });
1186 return reader.read(new Uint8Array(buffer, 8, 8)).then(result => {
1225 const reader = stream.getReader({ mode: 'byob' });
1227 return reader.read(new Uint8Array(24)).then(result => {
1255 const reader = stream.getReader({ mode: 'byob' });
1257 return reader.read(new Uint8Array(24)).then(result => {
1285 const reader = stream.getReader({ mode: 'byob' });
1287 return reader.read(new Uint8Array(8)).then(result => {
1295 return reader.read(new Uint8Array(8));
1334 const reader = stream.getReader({ mode: 'byob' });
1336 return reader.read(new Uint16Array(1)).then(result => {
1389 const reader = stream.getReader({ mode: 'byob' });
1391 const promise = reader.read(new Uint16Array(2)).then(result => {
1403 const p = reader.read(new Uint16Array(1));
1445 const reader = stream.getReader({ mode: 'byob' });
1448 return promise_rejects_js(t, TypeError, reader.read(new Uint16Array(1)), 'read(view) must fail')
1449 .then(() => promise_rejects_js(t, TypeError, reader.closed, 'reader.closed should reject'));
1468 const reader = stream.getReader({ mode: 'byob' });
1470 const readPromise = reader.read(new Uint16Array(1));
1475 .then(() => promise_rejects_js(t, TypeError, reader.closed, 'reader.closed must reject'));
1538 const reader = stream.getReader({ mode: 'byob' });
1540 return reader.read(new Uint8Array(16)).then(result => {
1548 return reader.read(new Uint8Array(16));
1594 const reader = stream.getReader({ mode: 'byob' });
1596 return reader.read(new Uint32Array(1)).then(result => {
1647 const reader = stream.getReader({ mode: 'byob' });
1649 return reader.read(new Uint32Array(1)).then(result => {
1689 const reader = stream.getReader();
1691 const p0 = reader.read().then(result => {
1710 const p1 = reader.read().then(result => {
1744 const reader = stream.getReader({ mode: 'byob' });
1746 const p0 = reader.read(new Uint8Array(16)).then(result => {
1755 const p1 = reader.read(new Uint8Array(32)).then(result => {
1781 const reader = stream.getReader({ mode: 'byob' });
1783 const p0 = reader.read(new Uint8Array(16)).then(result => {
1792 const p1 = reader.read(new Uint8Array(16)).then(result => {
1817 const reader = stream.getReader({ mode: 'byob' });
1822 return reader.read(new Uint8Array(7)).then(result => {
1851 const reader = stream.getReader({ mode: 'byob' });
1853 return promise_rejects_js(t, TypeError, reader.read(), 'read() must fail')
1862 const reader = stream.getReader({ mode: 'byob' });
1864 return promise_rejects_js(t, TypeError, reader.read({}), 'read(view) must fail');
1872 const reader = stream.getReader({ mode: 'byob' });
1875 reader.read({ buffer: new ArrayBuffer(10), byteOffset: 0, byteLength: 10 }),
1888 const reader = stream.getReader();
1890 return promise_rejects_exactly(t, error1, reader.read(), 'read() must fail');
1903 const reader = stream.getReader();
1905 const promise = promise_rejects_exactly(t, error1, reader.read(), 'read() must fail');
1921 const reader = stream.getReader({ mode: 'byob' });
1923 return promise_rejects_exactly(t, error1, reader.read(new Uint8Array(1)), 'read() must fail');
1936 const reader = stream.getReader({ mode: 'byob' });
1938 const promise = promise_rejects_exactly(t, error1, reader.read(new Uint8Array(1)), 'read() must fail');
1962 const reader = stream.getReader();
1964 const promise = promise_rejects_exactly(t, testError, reader.read(), 'read() must fail');
1965 return promise_rejects_exactly(t, testError, promise.then(() => reader.closed))
1981 const reader = stream.getReader();
1983 return promise_rejects_exactly(t, error1, reader.read(), 'read() must fail')
1984 .then(() => promise_rejects_exactly(t, error1, reader.closed, 'closed must fail'))
2002 const reader = stream.getReader({ mode: 'byob' });
2004 return promise_rejects_exactly(t, testError, reader.read(new Uint8Array(1)), 'read(view) must fail')
2005 .then(() => promise_rejects_exactly(t, testError, reader.closed, 'reader.closed must reject'))
2021 const reader = stream.getReader({ mode: 'byob' });
2023 return promise_rejects_exactly(t, error1, reader.read(new Uint8Array(1)), 'read(view) must fail')
2024 .then(() => promise_rejects_exactly(t, error1, reader.closed, 'closed must fail'))
2038 const reader = rs.getReader({ mode: 'byob' });
2040 return reader.read(view).then(() => {
2055 const reader = rs.getReader({ mode: 'byob' });
2056 return reader.read(newView()).then(() => {
2083 const reader = rs.getReader({ mode: 'byob' });
2084 const readPromise = reader.read(new Uint8Array(16));
2116 const reader = rs.getReader({ mode: 'byob' });
2117 const readPromise = reader.read(new Uint8Array(16));
2119 const cancelPromise = reader.cancel('meh');
2141 const reader = rs.getReader({ mode: 'byob' });
2142 const read = reader.read(new Uint8Array(16));
2146 reader.releaseLock();
2170 }, 'ReadableStream with byte source: default reader + autoAllocateChunkSize + byobRequest interaction');
2234 const reader = stream.getReader({ mode: 'byob' });
2236 const result = await reader.read(new Uint8Array([4, 5, 6]));
2258 const reader = stream.getReader({ mode: 'byob' });
2260 const result = await reader.read(new Uint8Array([4, 5, 6]));
2286 const reader = stream.getReader({ mode: 'byob' });
2287 const readPromise = reader.read(new Uint8Array([4, 5, 6]));
2326 const reader = stream.getReader({ mode: 'byob' });
2327 const readPromise = reader.read(new Uint8Array([4, 5, 6]));
2443 }, 'ReadableStream with byte source: releaseLock() with pending read(view), read(view) on second reader, respond()');
2490 }, 'ReadableStream with byte source: releaseLock() with pending read(view), read(view) on second reader with ' +
2535 }, 'ReadableStream with byte source: releaseLock() with pending read(view), read(view) on second reader with ' +
2572 }, 'ReadableStream with byte source: releaseLock() with pending read(view), read(view) on second reader, respondWithNewView()');
2606 }, 'ReadableStream with byte source: releaseLock() with pending read(view), read(view) on second reader, enqueue()');
2640 }, 'ReadableStream with byte source: releaseLock() with pending read(view), read(view) on second reader, ' +
2677 }, 'ReadableStream with byte source: autoAllocateChunkSize, releaseLock() with pending read(), read() on second reader, respond()');
2712 }, 'ReadableStream with byte source: autoAllocateChunkSize, releaseLock() with pending read(), read() on second reader, enqueue()');
2748 }, 'ReadableStream with byte source: autoAllocateChunkSize, releaseLock() with pending read(), read(view) on second reader, respond()');
2783 }, 'ReadableStream with byte source: autoAllocateChunkSize, releaseLock() with pending read(), read(view) on second reader, enqueue()');
2831 'second reader with 1 element Uint16Array, respond(1)');
2878 'second reader, enqueue()');
2892 const reader = stream.getReader();
2893 const result = await reader.read();