dart:async

Метод contains

Возвращает, содержится ли needle в элементах, предоставляемых этим потоком.

Сравнивает каждый элемент этого потока с needle с помощью Object.==. Если найден равный элемент, возвращаемое будущее завершается со значением true. Если этот поток завершается без совпадения, будущее завершается со значением false.

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

Пример:

final result = await Stream.fromIterable(['Year', 2021, 12, 24, 'Dart'])
    .contains('Dart');
print(result); // true

Реализация

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