summaryrefslogtreecommitdiffstats
path: root/futures/src/runtime.rs
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--futures/src/runtime.rs13
1 files changed, 10 insertions, 3 deletions
diff --git a/futures/src/runtime.rs b/futures/src/runtime.rs
index ede529dc..d204670b 100644
--- a/futures/src/runtime.rs
+++ b/futures/src/runtime.rs
@@ -95,11 +95,18 @@ where
&mut self,
subscription: Subscription<Hasher, Event, Message>,
) {
- let futures =
- self.subscriptions.update(subscription, self.sender.clone());
+ let Runtime {
+ executor,
+ subscriptions,
+ sender,
+ ..
+ } = self;
+
+ let futures = executor
+ .enter(|| subscriptions.update(subscription, sender.clone()));
for future in futures {
- self.executor.spawn(future);
+ executor.spawn(future);
}
}