dart:async

Метод pipe

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

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

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

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

Исходный код

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