Lines Matching refs:reader
277 const reader = r.getReader();
278 let res = await reader.read();
282 res = await reader.read();
295 const reader = r.getReader();
296 const res = await reader.read();
311 const reader = stream.getReader();
314 assert.strictEqual(reader[kState].stream, stream);
315 assert.strictEqual(stream[kState].reader, reader);
321 assert(reader instanceof ReadableStreamDefaultReader);
323 assert(isPromise(reader.closed));
324 assert.strictEqual(typeof reader.cancel, 'function');
325 assert.strictEqual(typeof reader.read, 'function');
326 assert.strictEqual(typeof reader.releaseLock, 'function');
328 const read1 = reader.read();
329 const read2 = reader.read();
336 assert.strictEqual(reader[kState].readRequests.length, 2);
341 reader.releaseLock();
347 const reader = stream.getReader();
348 const closedBefore = reader.closed;
350 reader.releaseLock();
352 const closedAfter = reader.closed;
356 assert.rejects(reader.read(), {
368 readableStreamReaderGenericRelease(stream[kState].reader);
377 readableStreamReaderGenericRelease(stream[kState].reader);
390 const reader = stream.getReader();
396 reader.cancel();
398 reader.read().then(common.mustCall(({ value, done }) => {
455 const reader = stream.getReader();
457 reader.closed.then(common.mustCall());
459 reader.read().then(common.mustCall(({ value, done }) => {
462 reader.read().then(common.mustCall(({ value, done }) => {
476 const reader = stream.getReader();
478 const closedBefore = reader.closed;
479 reader.releaseLock();
480 const closedAfter = reader.closed;
497 const reader = stream.getReader();
500 const closedBefore = reader.closed;
501 reader.releaseLock();
502 const closedAfter = reader.closed;
518 const reader = stream.getReader();
520 const cancel1 = reader.cancel();
521 const cancel2 = reader.cancel();
522 const closed = reader.closed;
541 const reader = stream.getReader();
544 const cancel1 = reader.cancel();
545 const cancel2 = reader.cancel();
546 const closed = reader.closed;
581 const reader = stream.getReader();
582 assert.rejects(reader.closed, error);
583 assert.rejects(reader.read(), error);
584 assert.rejects(reader.read(), error);
594 const reader = stream.getReader();
595 const cancel1 = reader.cancel();
596 const cancel2 = reader.cancel();
610 const reader = stream.getReader();
611 assert.rejects(reader.closed, error);
612 assert.rejects(reader.read(), error);
613 assert.rejects(reader.read(), error);
627 const reader = stream.getReader();
629 reader.read().then(common.mustCall(({ value, done }) => {
632 reader.read().then(common.mustCall(({ value, done }) => {
635 reader.read().then(common.mustCall(({ value, done }) => {
652 const reader = stream.getReader();
653 reader.read().then(common.mustCall(({ value, done }) => {
656 reader.read().then(common.mustCall(({ value, done }) => {
659 reader.read().then(common.mustNotCall());
680 const reader = stream.getReader();
682 await reader.read(), { value: 'a', done: false });
684 await reader.read(), { value: 'b', done: false });
686 await reader.read(), { value: undefined, done: true });
741 const reader = stream.getReader();
744 await reader.read(), { value: 'a', done: false });
746 await reader.read(), { value: 'b', done: false });
749 await reader.read(), { value: undefined, done: true });
852 const reader = stream.getReader();
856 reader.read().then(common.mustCall(({ value, done }) => {
860 reader.read().then(common.mustCall(({ value, done }) => {
892 const reader = stream.getReader();
893 reader.read().then(common.mustCall(({ value, done }) => {
897 reader.read().then(common.mustCall(({ value, done }) => {
914 const reader = stream.getReader();
915 reader.read().then(common.mustCall(({ value, done }) => {
919 reader.read().then(common.mustCall(({ value, done }) => {
923 reader.read().then(common.mustCall(({ value, done }) => {
944 const reader = stream.getReader();
947 await reader.read();
970 const reader = stream.getReader();
973 await reader.read();
974 await reader.read();
975 await reader.read();
993 const reader = stream.getReader();
996 await reader.read();
997 await reader.read();
998 await reader.read();
1028 const reader = stream.getReader();
1030 reader.closed.then(common.mustCall());
1039 const reader = stream.getReader();
1041 assert.rejects(reader.closed, error);
1054 const reader = stream.getReader();
1056 assert.rejects(reader.closed, error);
1114 const reader = stream.getReader();
1117 await reader.read();
1118 reader.releaseLock();
1189 const reader = stream.getReader();
1195 await reader.read();
1200 await reader.read();
1202 await reader.read();
1250 const reader = stream.getReader();
1252 let read = await reader.read();
1255 read = await reader.read();
1473 const reader = readable.getReader();
1476 inspect(reader),
1479 inspect(reader, { depth: null }),
1482 inspect(reader, { depth: 0 }),
1508 const reader = readable.getReader();
1509 reader.releaseLock();
1510 reader.releaseLock();
1511 assert.rejects(reader.read(), {
1514 assert.rejects(reader.cancel(), {
1576 const reader = stream.getReader();
1579 await reader.read();
1592 const reader = stream.getReader();
1595 await reader.read();
1608 const reader = stream.getReader();
1611 await reader.read();
1623 const reader = stream.getReader();
1626 await reader.read().catch(common.mustCall());
1638 const reader = stream.getReader();
1641 await reader.read().catch(common.mustCall());
1655 const reader = stream.getReader({ mode: 'byob' });
1657 reader.read(new DataView(buffer))
1677 const reader = stream.getReader({ mode: 'byob' });
1686 reader.read(view).then(common.mustCall(({ value }) => {