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.
rust-lang · Apr 24, 2018 · 822061b · 822061b
1 parent 1a52eba
commit 822061b
Show file tree

Hide file tree

Showing 6 changed files with 299 additions and 294 deletions.
diff --git a/futures-channel/benches/sync_mpsc.rs b/futures-channel/benches/sync_mpsc.rs
@@ -114,7 +114,6 @@ impl Stream for TestSender {
         try_ready!(self.tx.poll_ready(cx).map_err(|_| ()));
         self.tx.start_send(self.last + 1).unwrap();
         self.last += 1;
-        assert!(self.tx.poll_flush(cx).unwrap().is_ready());
         Ok(Async::Ready(Some(self.last)))
     }
 }