benchmark: add bytes variant to webstreams async-iterator

mcollina · RafaelGSS · commit 3b5baceafea8 · 2026-07-29T10:31:22.000-03:00
Signed-off-by: Matteo Collina <hello@matteocollina.com> PR-URL: #64291 Reviewed-By: Stephen Belanger <admin@stephenbelanger.com> Reviewed-By: Antoine du Hamel <duhamelantoine1995@gmail.com> Reviewed-By: Yagiz Nizipli <yagiz@nizipli.com> Reviewed-By: James M Snell <jasnell@gmail.com>
diff --git a/benchmark/webstreams/readable-async-iterator.js b/benchmark/webstreams/readable-async-iterator.js
@@ -6,23 +6,40 @@ const {
 
 const bench = common.createBenchmark(main, {
 n: [1e5],
+ type: ['normal', 'bytes'],
 });
 
 
-async function main({ n }) {
- const rs = new ReadableStream({
- pull: function(controller) {
- controller.enqueue(1);
- },
- });
+async function main({ n, type }) {
+ const rs = type === 'bytes' ?
+ new ReadableStream({
+ type: 'bytes',
+ pull: function(controller) {
+ controller.enqueue(new Uint8Array(1));
+ },
+ }) :
+ new ReadableStream({
+ pull: function(controller) {
+ controller.enqueue(1);
+ },
+ });
 
 let x = 0;
 
 bench.start();
- for await (const chunk of rs) {
- x += chunk;
- if (x > n) {
- break;
+ if (type === 'bytes') {
+ for await (const chunk of rs) {
+ x += chunk.byteLength;
+ if (x > n) {
+ break;
+ }
+ }
+ } else {
+ for await (const chunk of rs) {
+ x += chunk;
+ if (x > n) {
+ break;
+ }
 }
 }
 // Use x to ensure V8 does not optimize away the loop as a noop.

-Original file line number
+Diff line change
 constbench=common.createBenchmark(main,{
 n: [1e5],
 +type: ['normal','bytes'],
 });
 -asyncfunctionmain({ n }){
 -constrs=newReadableStream({
 -pull: function(controller){
 -controller.enqueue(1);
 -},
 -});
 +asyncfunctionmain({ n, type }){
 +constrs=type==='bytes' ?
 +newReadableStream({
 +type: 'bytes',
 +pull: function(controller){
 +controller.enqueue(newUint8Array(1));
 +},
 +}) :
 +newReadableStream({
 +pull: function(controller){
 +controller.enqueue(1);
 +},
 +});
 letx=0;
 bench.start();
 -forawait(constchunkofrs){
 -x+=chunk;
 -if(x>n){
 -break;
 +if(type==='bytes'){
 +forawait(constchunkofrs){
 +x+=chunk.byteLength;
 +if(x>n){
 +break;
 +}
 +}
 +}else{
 +forawait(constchunkofrs){
 +x+=chunk;
 +if(x>n){
 +break;
 +}
+}
+}
 // Use x to ensure V8 does not optimize away the loop as a noop.