dart:async

метод pipe

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

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

Возвращает future, который завершается после того, как этот поток обработан, а consumer закрыт.

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

Реализация

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