diff --git a/lib/internal/webstreams/adapters.js b/lib/internal/webstreams/adapters.js index 8befa6bbbafd72..73abd095dadfe5 100644 --- a/lib/internal/webstreams/adapters.js +++ b/lib/internal/webstreams/adapters.js @@ -183,7 +183,12 @@ function newWritableStreamFromStreamWritable(streamWritable, options = kEmptyObj const strategy = streamWritable.writableObjectMode ? new CountQueuingStrategy({ highWaterMark }) : - { highWaterMark }; + { + highWaterMark, + size(chunk) { + return chunk?.byteLength ?? chunk?.length ?? 1; + }, + }; let controller; let backpressurePromise;