dart:async

Метод skipWhile

Пропускает события данных из этого потока, пока они соответствуют test.

Возвращает поток, который выдаёт те же события, что и этот поток, за исключением того, что события данных не выдаются, пока событие данных не перестанет соответствовать test. Проверка завершается неудачей, если при вызове для события данных возвращается значение, не являющееся true, или если вызов test вызывает исключение. Если вызов вызывает исключение, оно выдаётся как событие ошибки в возвращаемом потоке вместо события данных; в противном случае событие, из-за которого test вернуло значение, не равное true, выдаётся как первое событие данных.

События ошибок и завершения передаются возвращаемым потоком без изменений.

Если этот поток является широковещательным, возвращаемый поток также является широковещательным. Для широковещательного потока проверка событий начинается только с момента, когда на возвращаемый поток подписываются.

Пример:

final stream = Stream<int>.periodic(const Duration(seconds: 1), (i) => i)
    .take(10)
    .skipWhile((x) => x < 5);
stream.forEach(print); // Outputs events: 5, ..., 9.

Реализация

Stream<T> skipWhile(bool test(T element)) {
  return new _SkipWhileStream<T>(this, test);
}