1 files changed, 4 insertions, 2 deletions
diff --git a/futures/src/runtime.rs b/futures/src/runtime.rs
index 3be45a26..ede529dc 100644
--- a/futures/src/runtime.rs
+++ b/futures/src/runtime.rs
@@ -73,11 +73,13 @@ where
         for future in futures {
             let mut sender = self.sender.clone();
 
-            self.executor.spawn(future.then(|message| async move {
+            let future = future.then(|message| async move {
                 let _ = sender.send(message).await;
 
                 ()
-            }));
+            });
+
+            self.executor.spawn(future);
         }
     }