@@ -1457,6 +1457,32 @@ added: v16.7.0
14571457* Returns: {Promise} Fulfills with an `  ArrayBuffer `  containing the full
14581458  contents of the stream. 
14591459
1460+ ` ` `  mjs
1461+ import  { buffer  as  arrayBuffer  } from  ' node:stream/consumers'  ;
1462+ import  { Readable  } from  ' node:stream'  ;
1463+ import  { TextEncoder  } from  ' node:util'  ;
1464+ 
1465+ const  encoder  =  new  TextEncoder ();
1466+ const  dataArray  =  encoder .encode (' hello world from consumers!'  );
1467+ 
1468+ const  readable  =  Readable .from (dataArray);
1469+ const  data  =  await  arrayBuffer (readable);
1470+ console .log (` from readable: ${ data .byteLength } `  );
1471+ ` ` ` 
1472+ 
1473+ ` ` `  cjs
1474+ const  { arrayBuffer  } =  require (' node:stream/consumers'  );
1475+ const  { Readable  } =  require (' stream'  );
1476+ const  { TextEncoder  } =  require (' util'  );
1477+ 
1478+ const  encoder  =  new  TextEncoder ();
1479+ const  dataArray  =  encoder .encode ([' hello world from consumers!'  ]);
1480+ const  readable  =  Readable .from (dataArray);
1481+ arrayBuffer (readable).then ((data ) =>  {
1482+   console .log (` from readable: ${ data .byteLength } `  );
1483+ });
1484+ ` ` ` 
1485+ 
14601486#### `  streamConsumers .blob (stream)` 
14611487
14621488<!-- YAML 
@@ -1467,6 +1493,27 @@ added: v16.7.0
14671493* Returns: {Promise} Fulfills with a {Blob} containing the full contents 
14681494  of the stream. 
14691495
1496+ ` ` `  mjs
1497+ import  { blob  } from  ' node:stream/consumers'  ;
1498+ 
1499+ const  dataBlob  =  new  Blob ([' hello world from consumers!'  ]);
1500+ 
1501+ const  readable  =  dataBlob .stream ();
1502+ const  data  =  await  blob (readable);
1503+ console .log (` from readable: ${ data .size } `  );
1504+ ` ` ` 
1505+ 
1506+ ` ` `  cjs
1507+ const  { blob  } =  require (' node:stream/consumers'  );
1508+ 
1509+ const  dataBlob  =  new  Blob ([' hello world from consumers!'  ]);
1510+ 
1511+ const  readable  =  dataBlob .stream ();
1512+ blob (readable).then ((data ) =>  {
1513+   console .log (` from readable: ${ data .size } `  );
1514+ });
1515+ ` ` ` 
1516+ 
14701517#### `  streamConsumers .buffer (stream)` 
14711518
14721519<!-- YAML 
@@ -1477,6 +1524,31 @@ added: v16.7.0
14771524* Returns: {Promise} Fulfills with a {Buffer} containing the full 
14781525  contents of the stream. 
14791526
1527+ ` ` `  mjs
1528+ import  { buffer  } from  ' node:stream/consumers'  ;
1529+ import  { Readable  } from  ' node:stream'  ;
1530+ import  { Buffer  } from  ' node:buffer'  ;
1531+ 
1532+ const  dataBuffer  =  Buffer .from (' hello world from consumers!'  );
1533+ 
1534+ const  readable  =  Readable .from (dataBuffer);
1535+ const  data  =  await  buffer (readable);
1536+ console .log (` from readable: ${ data .length } `  );
1537+ ` ` ` 
1538+ 
1539+ ` ` `  cjs
1540+ const  { buffer  } =  require (' node:stream/consumers'  );
1541+ const  { Readable  } =  require (' node:stream'  );
1542+ const  { Buffer  } =  require (' node:buffer'  );
1543+ 
1544+ const  dataBuffer  =  Buffer .from (' hello world from consumers!'  );
1545+ 
1546+ const  readable  =  Readable .from (dataBuffer);
1547+ buffer (readable).then ((data ) =>  {
1548+   console .log (` from readable: ${ data .length } `  );
1549+ });
1550+ ` ` ` 
1551+ 
14801552#### `  streamConsumers .json (stream)` 
14811553
14821554<!-- YAML 
@@ -1487,6 +1559,43 @@ added: v16.7.0
14871559* Returns: {Promise} Fulfills with the contents of the stream parsed as a 
14881560  UTF-8 encoded string that is then passed through `  JSON .parse ()` .
14891561
1562+ ` ` `  mjs
1563+ import  { json  } from  ' node:stream/consumers'  ;
1564+ import  { Readable  } from  ' node:stream'  ;
1565+ 
1566+ const  items  =  Array .from (
1567+   {
1568+     length:  100 
1569+   },
1570+   () =>  ({
1571+     message:  ' hello world from consumers!' 
1572+   })
1573+ );
1574+ 
1575+ const  readable  =  Readable .from (JSON .stringify (items));
1576+ const  data  =  await  json (readable);
1577+ console .log (` from readable: ${ data .length } `  );
1578+ ` ` ` 
1579+ 
1580+ ` ` `  cjs
1581+ const  { json  } =  require (' node:stream/consumers'  );
1582+ const  { Readable  } =  require (' node:stream'  );
1583+ 
1584+ const  items  =  Array .from (
1585+   {
1586+     length:  100 
1587+   },
1588+   () =>  ({
1589+     message:  ' hello world from consumers!' 
1590+   })
1591+ );
1592+ 
1593+ const  readable  =  Readable .from (JSON .stringify (items));
1594+ json (readable).then ((data ) =>  {
1595+   console .log (` from readable: ${ data .length } `  );
1596+ });
1597+ ` ` ` 
1598+ 
14901599#### `  streamConsumers .text (stream)` 
14911600
14921601<!-- YAML 
@@ -1497,5 +1606,24 @@ added: v16.7.0
14971606* Returns: {Promise} Fulfills with the contents of the stream parsed as a 
14981607  UTF-8 encoded string. 
14991608
1609+ ` ` `  mjs
1610+ import  { json , text , blob , buffer  } from  ' node:stream/consumers'  ;
1611+ import  { Readable  } from  ' node:stream'  ;
1612+ 
1613+ const  readable  =  Readable .from (' Hello world from consumers!'  );
1614+ const  data  =  await  text (readable);
1615+ console .log (` from readable: ${ data .length } `  );
1616+ ` ` ` 
1617+ 
1618+ ` ` `  cjs
1619+ const  { text  } =  require (' node:stream/consumers'  );
1620+ const  { Readable  } =  require (' node:stream'  );
1621+ 
1622+ const  readable  =  Readable .from (' Hello world from consumers!'  );
1623+ text (readable).then ((data ) =>  {
1624+   console .log (` from readable: ${ data .length } `  );
1625+ });
1626+ ` ` ` 
1627+ 
15001628[Streams]: stream.md 
15011629[WHATWG Streams Standard]: https://streams.spec.whatwg.org/ 
0 commit comments