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 USubscription for RpcClientUSubscription

fn subscribe<'life0, 'async_trait>( &'life0 self, subscription_request: SubscriptionRequest, ) -> Pin<Box<dyn Future<Output = Result<SubscriptionResponse, UStatus>> + Send + 'async_trait>>

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

Subscribe to a topic, using a SubscriptionRequest

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

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

Unsubscribe to a topic, using an UnsubscribeRequest

fn fetch_subscriptions<'life0, 'async_trait>( &'life0 self, fetch_subscriptions_request: FetchSubscriptionsRequest, ) -> Pin<Box<dyn Future<Output = Result<FetchSubscriptionsResponse, UStatus>> + Send + 'async_trait>>

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

Fetch all subscriptions for a given topic or subscriber contained inside a FetchSubscriptionsRequest

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

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

Register for notifications relevant to a given topic inside a NotificationsRequest changing in subscription status.

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

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

Unregister for notifications relevant to a given topic inside a NotificationsRequest changing in subscription status.

fn fetch_subscribers<'life0, 'async_trait>( &'life0 self, fetch_subscribers_request: FetchSubscribersRequest, ) -> Pin<Box<dyn Future<Output = Result<FetchSubscribersResponse, UStatus>> + Send + 'async_trait>>

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

Fetch a list of subscribers that are currently subscribed to a given topic in a FetchSubscribersRequest