Skip to content

Commit 4d2509f

Browse files
committed
Channel refactor
Refactors channels to use "waker" terminology rather than "parking" Splits unbounded channels into a separate, simplified underlying type Calls poll_ready in poll_flush impl for bounded channels in order to provide backpressure on <Sender as Sink>::send.
1 parent 1a52eba commit 4d2509f

File tree

6 files changed

+304
-305
lines changed

6 files changed

+304
-305
lines changed

futures-channel/benches/sync_mpsc.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,6 @@ impl Stream for TestSender {
114114
try_ready!(self.tx.poll_ready(cx).map_err(|_| ()));
115115
self.tx.start_send(self.last + 1).unwrap();
116116
self.last += 1;
117-
assert!(self.tx.poll_flush(cx).unwrap().is_ready());
118117
Ok(Async::Ready(Some(self.last)))
119118
}
120119
}

0 commit comments

Comments
 (0)