diff --git a/src/runtime2/scheduler.rs b/src/runtime2/scheduler.rs index e9d8a99c89c6b4df70ce847c352ab97d8de02f2e..b772b87602a537819130076dfe9751d213c33a2f 100644 --- a/src/runtime2/scheduler.rs +++ b/src/runtime2/scheduler.rs @@ -51,7 +51,11 @@ impl Scheduler { new_schedule = connector.run_in_speculative_mode(self.code.as_ref(), &mut delta_state); debug_assert!(delta_state.new_connectors.is_empty()); - if !delta_state.outbox.is_empty() {} + if !delta_state.outbox.is_empty() { + for message in delta_state.outbox.drain(..) { + + } + } } else { // In regular running mode (not in a sync block) we cannot send // messages but we can create new connectors