fold<S> 方法

Future<S> fold<S>(
  1. S initialValue,
  2. S combine(
    1. S previous,
    2. T element
    )
)

通过反复应用 combine 将一系列值组合起来。

类似于 Iterable.fold，此函数维护一个值，从 initialValue 开始，并更新为流中每个元素的值。对于每个元素，该值更新为通过使用上一个值和元素调用 combine 得到的结果。

当此流完成时，返回的 future 以当时的价值完成。对于空流，future 以 initialValue 完成。

如果此流发出错误，或者 combine 调用抛出异常，则返回的 future 以该错误完成，并且处理停止。

示例

final result = await Stream.fromIterable([2, 6, 10, 8, 2])
    .fold<int>(10, (previous, element) => previous + element);
print(result); // 38

实现

Future<S> fold<S>(S initialValue, S combine(S previous, T element)) {
  _Future<S> result = new _Future<S>();
  S value = initialValue;
  StreamSubscription<T> subscription =
      this.listen(null, onError: result._completeError, onDone: () {
    result._complete(value);
  }, cancelOnError: true);
  subscription.onData((T element) {
    _runUserCode(() => combine(value, element), (S newValue) {
      value = newValue;
    }, _cancelAndErrorClosure(subscription, result));
  });
  return result;
}