pub fn supervise_undeliverable_messages_with<R, F>(
rx: PortReceiver<Undeliverable<MessageEnvelope>>,
resolve_sink: R,
on_undeliverable: F,
)where
R: FnMut() -> Option<PortHandle<ActorSupervisionEvent>> + Send + 'static,
F: Fn(&MessageEnvelope) + Send + Sync + 'static,Expand description
Drain undeliverables and convert them into
ActorSupervisionEvent, using a caller-provided resolver to
obtain the (possibly late) sink. If the resolver returns None,
we log and drop the undeliverable.