hyperactor::mailbox

Function supervise_undeliverable_messages

Source 
pub fn supervise_undeliverable_messages<F>(
    supervision_port: PortHandle<ActorSupervisionEvent>,
    rx: PortReceiver<Undeliverable<MessageEnvelope>>,
    on_deliverable: F,
)
where
    F: Fn(&MessageEnvelope) + Send + Sync + 'static,
Expand description

Spawns a task that listens for undeliverable messages and posts a corresponding ActorSupervisionEvent to the given supervision port.