dart:async

Метод drain<E>

Отбрасывает все данные из этого потока, но сигнализирует, когда он завершен или произошла ошибка.

При подписке с помощью drain, cancelOnError будет true. Это означает, что будущее будет завершено первой ошибкой в этом потоке, а затем отменит подписку.

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

В случае done события будущее завершается заданным futureValue.

futureValue не должно быть опущено, если null не может быть присвоено E.

Пример:

final result = await Stream.fromIterable([1, 2, 3]).drain(100);
print(result); // Outputs: 100.

Реализация

Future<E> drain<E>([E? futureValue]) {
  if (futureValue == null) {
    futureValue = futureValue as E;
  }
  return listen(null, cancelOnError: true).asFuture<E>(futureValue);
}