Lines Matching refs:stream
5 const { isDisturbed, isErrored, isReadable } = require('stream');
24 } = require('stream/web');
310 const stream = new ReadableStream();
311 const reader = stream.getReader();
313 assert(stream.locked);
314 assert.strictEqual(reader[kState].stream, stream);
315 assert.strictEqual(stream[kState].reader, reader);
317 assert.throws(() => stream.getReader(), {
340 assert(stream.locked);
342 assert(!stream.locked);
346 const stream = new ReadableStream();
347 const reader = stream.getReader();
349 assert(stream.locked);
351 assert(!stream.locked);
366 const stream = new ReadableStream();
367 const iterable = stream.values();
368 readableStreamReaderGenericRelease(stream[kState].reader);
375 const stream = new ReadableStream();
376 const iterable = stream.values();
377 readableStreamReaderGenericRelease(stream[kState].reader);
384 const stream = new ReadableStream({
390 const reader = stream.getReader();
392 assert.rejects(stream.cancel(), {
405 const stream = new ReadableStream({
410 assert(!stream.locked);
412 const cancel1 = stream.cancel();
413 const cancel2 = stream.cancel();
423 const stream = new ReadableStream({
429 stream.getReader().releaseLock();
430 stream.getReader().releaseLock();
431 stream.getReader();
435 const stream = new ReadableStream({
441 stream.getReader();
443 assert.throws(() => stream.getReader(), {
449 const stream = new ReadableStream({
455 const reader = stream.getReader();
470 const stream = new ReadableStream({
476 const reader = stream.getReader();
491 const stream = new ReadableStream({
497 const reader = stream.getReader();
512 const stream = new ReadableStream({
518 const reader = stream.getReader();
535 const stream = new ReadableStream({
541 const reader = stream.getReader();
558 const stream = new ReadableStream();
559 const cancel1 = stream.cancel();
560 const cancel2 = stream.cancel();
567 stream.getReader().read().then(common.mustCall(({ value, done }) => {
575 const stream = new ReadableStream({
580 stream.getReader().releaseLock();
581 const reader = stream.getReader();
589 const stream = new ReadableStream({
594 const reader = stream.getReader();
604 const stream = new ReadableStream({
609 stream.getReader().releaseLock();
610 const reader = stream.getReader();
620 const stream = new ReadableStream({
627 const reader = stream.getReader();
646 const stream = new ReadableStream({
652 const reader = stream.getReader();
666 const stream = new ReadableStream({
674 const { 0: s1, 1: s2 } = stream.tee();
679 async function read(stream) {
680 const reader = stream.getReader();
697 const stream = new ReadableStream({
705 const { 0: s1, 1: s2 } = stream.tee();
707 assert(stream.locked);
725 const stream = new ReadableStream({
733 const { 0: s1, 1: s2 } = stream.tee();
740 async function read(stream, canceled = false) {
741 const reader = stream.getReader();
762 const stream = new ReadableStream({
768 const { 0: s1, 1: s2 } = stream.tee();
777 const stream = new ReadableStream({
783 const { 0: s1, 1: s2 } = stream.tee();
791 const stream = new ReadableStream({
797 const { 0: s1, 1: s2 } = stream.tee();
806 const stream = new ReadableStream({
812 const { 0: s1, 1: s2 } = stream.tee();
822 const stream = new ReadableStream({
828 const { 0: s1, 1: s2 } = stream.tee();
844 const stream = new ReadableStream({
852 const reader = stream.getReader();
870 const stream = new ReadableStream({
877 stream.getReader().read().then(common.mustCall(({ value, done }) => {
884 const stream = new ReadableStream({
892 const reader = stream.getReader();
905 const stream = new ReadableStream({
914 const reader = stream.getReader();
936 const stream = new ReadableStream({
944 const reader = stream.getReader();
958 const stream = new ReadableStream({
970 const reader = stream.getReader();
980 const stream = new ReadableStream({
993 const reader = stream.getReader();
1024 const stream = new ReadableStream({
1028 const reader = stream.getReader();
1035 const stream = new ReadableStream({
1039 const reader = stream.getReader();
1047 const stream = new ReadableStream({
1054 const reader = stream.getReader();
1113 const stream = new ReadableStream(source);
1114 const reader = stream.getReader();
1119 stream.cancel();
1183 const stream = new ReadableStream({
1189 const reader = stream.getReader();
1227 this.stream = createReadStream(__filename);
1228 this.stream.on('data', (chunk) => {
1231 this.stream.once('end', () => {
1235 this.stream.once('error', (error) => {
1247 const stream = new ReadableStream(source);
1249 async function read(stream) {
1250 const reader = stream.getReader();
1260 read(stream).then(common.mustCall((data) => {
1268 const stream = new ReadableStream(source);
1270 async function read(stream) {
1272 for await (const chunk of stream)
1277 read(stream).then(common.mustCall((data) => {
1281 assert.strictEqual(stream[kState].state, 'closed');
1282 assert(!stream.locked);
1288 const stream = new ReadableStream(source);
1291 assert.throws(() => stream.values(options), {
1296 async function read(stream) {
1297 for await (const _ of stream.values({ preventCancel: true }))
1301 read(stream).then(common.mustCall((data) => {
1302 assert.strictEqual(stream[kState].state, 'readable');
1308 const stream = new ReadableStream(source);
1310 async function read(stream) {
1311 for await (const _ of stream.values({ preventCancel: false }))
1315 read(stream).then(common.mustCall((data) => {
1316 assert.strictEqual(stream[kState].state, 'closed');
1322 const stream = new ReadableStream(source);
1326 async function read(stream) {
1328 for await (const _ of stream.values({ preventCancel: true }))
1332 assert.rejects(read(stream), error).then(common.mustCall(() => {
1333 assert.strictEqual(stream[kState].state, 'readable');
1339 const stream = new ReadableStream(source);
1343 async function read(stream) {
1345 for await (const _ of stream.values({ preventCancel: false }))
1349 assert.rejects(read(stream), error).then(common.mustCall(() => {
1350 assert.strictEqual(stream[kState].state, 'closed');
1568 const stream = new ReadableStream({
1576 const reader = stream.getReader();
1578 isDisturbed(stream, false);
1580 isDisturbed(stream, true);
1585 const stream = new ReadableStream({
1592 const reader = stream.getReader();
1594 isDisturbed(stream, false);
1596 isDisturbed(stream, true);
1601 const stream = new ReadableStream({
1606 stream.cancel();
1608 const reader = stream.getReader();
1610 isDisturbed(stream, false);
1612 isDisturbed(stream, true);
1617 const stream = new ReadableStream({
1623 const reader = stream.getReader();
1625 isErrored(stream, false);
1627 isErrored(stream, true);
1632 const stream = new ReadableStream({
1638 const reader = stream.getReader();
1640 isReadable(stream, true);
1642 isReadable(stream, false);
1647 const stream = new ReadableStream({
1655 const reader = stream.getReader({ mode: 'byob' });
1662 const stream = new ReadableStream({
1677 const reader = stream.getReader({ mode: 'byob' });