dart:async

Метод elementAt

Возвращает значение index-го события данных этого потока.

Прекращает прослушивание этого потока после получения index-го события данных.

Внутри метод отменяет свою подписку после этих элементов. Это означает, что потоки с единственной подпиской (не широковещательные) закрываются и не могут быть повторно использованы после вызова этого метода.

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

Если событие завершения происходит до нахождения значения, будущее завершается с RangeError.

Реализация

Future<T> elementAt(int index) {
  RangeError.checkNotNegative(index, "index");
  _Future<T> result = new _Future<T>();
  int elementIndex = 0;
  StreamSubscription<T> subscription;
  subscription =
      this.listen(null, onError: result._completeError, onDone: () {
    result._completeError(
        new RangeError.index(index, this, "index", null, elementIndex),
        StackTrace.empty);
  }, cancelOnError: true);
  subscription.onData((T value) {
    if (index == elementIndex) {
      _cancelAndValue(subscription, result, value);
      return;
    }
    elementIndex += 1;
  });

  return result;
}