Skip to content

Commit a00d35e

Browse files
mzabaluevcramertj
authored andcommitted
Don't bypass stream fuse in 0.1 Forward
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.
1 parent 56f8eb9 commit a00d35e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/stream/forward.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ impl<T, U> Future for Forward<T, U>
9191
}
9292

9393
loop {
94-
match self.stream_mut()
94+
match self.stream.as_mut()
9595
.expect("Attempted to poll Forward after completion")
9696
.poll()?
9797
{

0 commit comments

Comments
 (0)