diff --git a/src/runtime2/scheduler.rs b/src/runtime2/scheduler.rs index cdc329f9892abb8c3a290a7528604c5773899328..c2b6c834d7720443944a418ba07dd0353de7499e 100644 --- a/src/runtime2/scheduler.rs +++ b/src/runtime2/scheduler.rs @@ -95,9 +95,7 @@ impl Scheduler { let port_info = &component.ctx.ports[port_index]; if let Some((peer_id, message)) = component.code.control.mark_port_closed(port_info.self_id, &mut component.ctx) { let peer_info = component.ctx.get_peer(peer_id); - peer_info.handle.inbox.push(Message::Control(message)); - - wake_up_if_sleeping(sched_ctx, peer_id, &peer_info.handle); + peer_info.handle.send_message(sched_ctx, Message::Control(message), true); } }