dart:async

Метод forEach

Выполняет action над каждым элементом этого потока.

Завершает возвращаемое Future, когда все элементы этого потока будут обработаны.

Если этот поток генерирует ошибку или вызов action вызывает ошибку, возвращаемое будущее завершается с этой ошибкой, и обработка останавливается.

Реализация

Future forEach(void action(T element)) {
  _Future future = new _Future();
  StreamSubscription<T> subscription =
      this.listen(null, onError: future._completeError, onDone: () {
    future._complete(null);
  }, cancelOnError: true);
  subscription.onData((T element) {
    _runUserCode<void>(() => action(element), (_) {},
        _cancelAndErrorClosure(subscription, future));
  });
  return future;
}