Struct RpcClientUSubscription

pub struct RpcClientUSubscription { /* private fields */ }

A USubscription client implementation for invoking operations of a local USubscription service.

The client requires an RpcClient for performing the remote procedure calls.

Implementations

impl RpcClientUSubscription

pub fn new(rpc_client: Arc<dyn RpcClient>) -> Self

Creates a new Notifier for a given transport.

Arguments

• rpc_client - The client to use for performing the remote procedure calls on the USubscription service.

Trait Implementations

impl Debug for RpcClientUSubscription

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl USubscription for RpcClientUSubscription

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 UUri, expiration: Option<u64>, min_sample_period: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<SubscriptionStatus, UStatus>> + Send + 'async_trait>>

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

Subscribes to a topic.

fn unsubscribe<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 UUri, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

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

Unsubscribes this client from a topic.

fn fetch_subscriptions_by_topic<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 UUri, ) -> Pin<Box<dyn Future<Output = Result<Vec<SubscriptionInfo>, UStatus>> + Send + 'async_trait>>

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

Gets all (currently) active subscriptions for a given topic.

fn fetch_subscriptions_by_subscriber<'life0, 'life1, 'async_trait>( &'life0 self, subscriber: &'life1 UUri, ) -> Pin<Box<dyn Future<Output = Result<Vec<SubscriptionInfo>, UStatus>> + Send + 'async_trait>>

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

Gets a uEntity’s (currently) active subscriptions.

fn register_for_notifications<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 UUri, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

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

Registers this client for notifications about changes to the subscription status for a given topic.

fn unregister_for_notifications<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 UUri, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

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

Unregisters this client from notifications about changes to the subscription status for a given topic.

fn fetch_subscribers<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 UUri, ) -> Pin<Box<dyn Future<Output = Result<Vec<UUri>, UStatus>> + Send + 'async_trait>>

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

Fetches a list of subscribers that are currently subscribed to a given topic.

fn reset<'life0, 'async_trait>( &'life0 self, reason: ResetReason, message: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flushes all stored subscription information, including any persistently stored subscriptions.