Skip to content

Commit

Permalink
Don't bypass stream fuse in 0.1 Forward
Browse files Browse the repository at this point in the history
The poll implementation for Forward used method stream_mut
to get at the stream. This bypasses the Fuse that was meant to
prevent stream from being polled more than once in case
close() on the sink initially returns NotReady.
  • Loading branch information
mzabaluev authored and cramertj committed Sep 12, 2019
1 parent 56f8eb9 commit a00d35e
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/stream/forward.rs
Expand Up @@ -91,7 +91,7 @@ impl<T, U> Future for Forward<T, U>
}

loop {
match self.stream_mut()
match self.stream.as_mut()
.expect("Attempted to poll Forward after completion")
.poll()?
{
Expand Down

0 comments on commit a00d35e

Please sign in to comment.