Fix channel dec logic

Fixes tokio-rs#463
zhuhaow · Sep 13, 2016 · 0d3e9ea · 0d3e9ea
1 parent 68aaf8b
commit 0d3e9ea
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/channel.rs b/src/channel.rs
@@ -235,11 +235,11 @@ impl ReceiverCtl {
         // Decrement
         let second = self.inner.pending.fetch_sub(1, Ordering::AcqRel);
 
-        if first == 1 && second > 0 {
+        if first == 1 && second > 1 {
             // There are still pending messages. Since readiness was
             // previously unset, it must be reset here
             if let Some(set_readiness) = self.inner.set_readiness.borrow() {
-                try!(set_readiness.set_readiness(Ready::none()));
+                try!(set_readiness.set_readiness(Ready::readable()));
             }
         }