dart:async

Метод contains

Проверяет, встречается ли needle в элементах, предоставляемых этим потоком.

Завершает Future, когда ответ известен. Если этот поток сообщает об ошибке, Future сообщит об этой ошибке.

Исходный код

Future<bool> contains(Object needle) {
  _Future<bool> future = new _Future<bool>();
  StreamSubscription subscription;
  subscription = this.listen(
      (T element) {
        _runUserCode(() => (element == needle), (bool isMatch) {
          if (isMatch) {
            _cancelAndValue(subscription, future, true);
          }
        }, _cancelAndErrorClosure(subscription, future));
      },
      onError: future._completeError,
      onDone: () {
        future._complete(false);
      },
      cancelOnError: true);
  return future;
}