readableStream.pipe(Stream.scan(
{ done: false, length: 0, chunks: [] as Uint8Array[] },
(accumulator, newChunk) => {
const length = accumulator.length + newChunk.length
accumulator.chunks.push(newChunk)
return { length, chunks: accumulator.chunks, done: false }
},
))
readableStream.pipe(Stream.scan(
{ done: false, length: 0, chunks: [] as Uint8Array[] },
(accumulator, newChunk) => {
const length = accumulator.length + newChunk.length
accumulator.chunks.push(newChunk)
return { length, chunks: accumulator.chunks, done: false }
},
))