dart:async

Метод where

Создает новый поток из этого потока, который отбрасывает некоторые события данных.

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

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

Исходный код

Stream<T> where(bool test(T event)) {
  return new _WhereStream<T>(this, test);
}