diff --git a/src/sources/futures.rs b/src/sources/futures.rs
index 3a56e005..65e3fc30 100644
--- a/src/sources/futures.rs
+++ b/src/sources/futures.rs
@@ -296,9 +296,6 @@ impl<T> EventSource for Executor<T> {
     {
         let state = &self.state;
 
-        // Set to the unnotified state.
-        state.sender.notified.store(false, Ordering::SeqCst);
-
         let clear_readiness = {
             let mut clear_readiness = false;
 
@@ -347,6 +344,9 @@ impl<T> EventSource for Executor<T> {
                 .map_err(ExecutorError::WakeError)?;
         }
 
+        // Set to the unnotified state.
+        state.sender.notified.store(false, Ordering::SeqCst);
+
         Ok(PostAction::Continue)
     }