readable.reduce(fn[, initial[, options]])

• fn <Function> | <AsyncFunction> 是一个在流中的每个数据块上调用的归约函数。
  • previous <any> 上一次调用 fn 获得的值，如果指定了 initial 值则使用该值，否则使用流的第一个块。
  • data <any> 从流中获取一块数据。
  • options <Object>
    • signal <AbortSignal> 如果流被销毁则中止，从而允许提前中止 fn 调用。
• initial <any> 用于归约的初始值。
• options <Object>
  • signal <AbortSignal> 允许在信号被中止时销毁流。
• 返回：<Promise> 一个用于归约最终值的 Promise。

此方法按顺序对流的每个块调用 fn，将前一个元素计算的结果传递给它。它返回一个表示归约最终值的 Promise。

🌐 This method calls fn on each chunk of the stream in order, passing it the result from the calculation on the previous element. It returns a promise for the final value of the reduction.

reducer 函数会逐元素迭代流，这意味着没有 concurrency 参数或并行处理。要并发执行 reduce，可以将其与 readable.map 方法链式调用。

🌐 The reducer function iterates the stream element-by-element which means that there is no concurrency parameter or parallelism. To perform a reduce concurrently, it can be chained to the readable.map method.

如果未提供 initial 值，则流的第一个数据块将用作初始值。如果流为空，Promise 将被拒绝，并返回一个 TypeError，其 code 属性为 ERR_INVALID_ARGS。

🌐 If no initial value is supplied the first chunk of the stream is used as the initial value. If the stream is empty, the promise is rejected with a TypeError with the ERR_INVALID_ARGS code property.

import { Readable } from 'node:stream';

const ten = await Readable.from([1, 2, 3, 4]).reduce((previous, data) => {
  return previous + data;
});
console.log(ten); // 10 拷贝