diff options
Diffstat (limited to '')
| -rw-r--r-- | futures/src/runtime.rs | 13 | 
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);          }      } | 
