Skip to main content

RemoteMessageSink

atomr_cluster

Trait RemoteMessageSink 

Source 
pub trait RemoteMessageSink:
    Send
    + Sync
    + 'static {
    // Required method
    fn deliver(
        &self,
        target_path: &str,
        manifest: &str,
        payload: &[u8],
        sender_path: Option<&str>,
    );
}
Expand description

Sink for inbound RemoteTell frames. The pycore binding implements this — typically by decoding the payload via the codec registry and invoking tell on the matching local actor.

Required Methods§

Source

fn deliver( &self, target_path: &str, manifest: &str, payload: &[u8], sender_path: Option<&str>, )

Deliver a RemoteTell frame. Errors must not crash the transport — the implementor is responsible for logging or dead-lettering.

Implementors§