diff --git a/tokio-reactor/src/atomic_task.rs b/tokio-reactor/src/atomic_task.rs index 1510eee26..9b4ba00ca 100644 --- a/tokio-reactor/src/atomic_task.rs +++ b/tokio-reactor/src/atomic_task.rs @@ -155,7 +155,7 @@ impl AtomicTask { if actual == curr { // Notify the task unsafe { - if let Some(ref task) = *self.task.get() { + if let Some(ref task) = (*self.task.get()).take() { task.notify(); } }