Struct SubscriptionManager 

pub struct SubscriptionManager {
    pub pending_acks: Arc<Mutex<HashMap<u64, Sender<Result<(), SubscriptionAckError>>>>>,
    /* private fields */
}

Fields

pending_acks: Arc<Mutex<HashMap<u64, Sender<Result<(), SubscriptionAckError>>>>>

Implementations

impl SubscriptionManager

pub fn new(tx: SlimChannelSender) -> Self

pub fn register_ack(&self) -> (u64, Receiver<Result<(), SubscriptionAckError>>)

Register a pending ACK entry and return the ack_id and receiver. The caller is responsible for building and sending the message with this ack_id. If sending fails, call cancel_ack to clean up.

pub fn register_ack_with_id( &self, id: u64, ) -> Receiver<Result<(), SubscriptionAckError>>

Register a pending ACK entry under a caller-provided ID and return the receiver.

pub fn cancel_ack(&self, ack_id: u64)

Remove a previously registered pending ACK (call on send failure).

pub async fn await_ack( ack_rx: Receiver<Result<(), SubscriptionAckError>>, ) -> Result<(), SubscriptionAckError>

Await a previously registered ACK receiver, with a deadline of [ACK_TIMEOUT].

Uses futures_timer::Delay rather than tokio::time::timeout so that this function works correctly outside a Tokio runtime with the time driver enabled (e.g. when called from UniFFI async bindings).

pub fn resolve_ack(&self, ack: &ProtoSubscriptionAck)

Called by the App message loop to complete a waiting future for an ACK.

Trait Implementations

impl Clone for SubscriptionManager

fn clone(&self) -> SubscriptionManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl SubscriptionOps for SubscriptionManager

fn subscribe<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source: &'life1 ProtoName, name: &'life2 ProtoName, forward_to: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<(u64, Receiver<Result<(), SubscriptionAckError>>), SubscriptionAckError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Subscribe (forward_to): register interest in name, optionally routing through a specific connection.

fn unsubscribe<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source: &'life1 ProtoName, name: &'life2 ProtoName, subscription_id: u64, forward_to: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Receiver<Result<(), SubscriptionAckError>>, SubscriptionAckError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Unsubscribe (forward_to): de-register interest in name.

fn set_route<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source: &'life1 ProtoName, name: &'life2 ProtoName, conn: u64, ) -> Pin<Box<dyn Future<Output = Result<(u64, Receiver<Result<(), SubscriptionAckError>>), SubscriptionAckError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Set a recv_from route for name on connection conn.

fn remove_route<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source: &'life1 ProtoName, name: &'life2 ProtoName, subscription_id: u64, conn: u64, ) -> Pin<Box<dyn Future<Output = Result<Receiver<Result<(), SubscriptionAckError>>, SubscriptionAckError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Remove a recv_from route for name on connection conn.

fn from_slim_tx(tx: &SlimChannelSender) -> Option<Self>

Called during session stack construction to create a default instance from the SLIM channel sender. Returns None if this type requires explicit construction (caller must call with_subscription_manager on the builder).