File tree 1 file changed +5
-9
lines changed
1 file changed +5
-9
lines changed Original file line number Diff line number Diff line change @@ -970,19 +970,15 @@ pub trait StreamExt: Stream {
970
970
}
971
971
972
972
/// A future that completes after the given stream has been fully processed
973
- /// into the sink, including flushing .
973
+ /// into the sink and the sink has been flushed and closed .
974
974
///
975
975
/// This future will drive the stream to keep producing items until it is
976
- /// exhausted, sending each item to the sink. It will complete once both the
977
- /// stream is exhausted and the sink has received and flushed all items.
978
- /// Note that the sink is **not** closed.
979
- ///
980
- /// Note that this combinator is only usable with `Unpin` sinks.
981
- /// Sinks that are not `Unpin` will need to be pinned in order to be used
982
- /// with `forward`.
976
+ /// exhausted, sending each item to the sink. It will complete once the
977
+ /// stream is exhausted, the sink has received and flushed all items, and
978
+ /// the sink is closed.
983
979
fn forward < S > ( self , sink : S ) -> Forward < Self , S >
984
980
where
985
- S : Sink + Unpin ,
981
+ S : Sink ,
986
982
Self : Stream < Item = Result < S :: SinkItem , S :: SinkError > > + Sized ,
987
983
{
988
984
Forward :: new ( self , sink)
You can’t perform that action at this time.
0 commit comments