dart:async

Метод pipe

Перенаправляет события этого потока в streamConsumer.

Все события этого потока добавляются в streamConsumer с помощью StreamConsumer.addStream. Поток streamConsumer закрывается, когда этот поток успешно добавлен в него — когда возвращаемое будущее addStream завершается без ошибок.

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

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

Реализация

Future pipe(StreamConsumer<T> streamConsumer) {
  return streamConsumer.addStream(this).then((_) => streamConsumer.close());
}