pub struct RpcClientUSubscription { /* private fields */ }
Expand description
A USubscription
client implementation for invoking operations of a local USubscription service.
The client requires an RpcClient
for performing the remote procedure calls.
Implementations§
Trait Implementations§
Source§impl USubscription for RpcClientUSubscription
impl USubscription for RpcClientUSubscription
Source§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,
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
Read moreSource§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,
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
Read moreSource§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,
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
Read moreSource§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,
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. Read moreSource§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,
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. Read moreSource§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,
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
Read moreAuto Trait Implementations§
impl Freeze for RpcClientUSubscription
impl !RefUnwindSafe for RpcClientUSubscription
impl Send for RpcClientUSubscription
impl Sync for RpcClientUSubscription
impl Unpin for RpcClientUSubscription
impl !UnwindSafe for RpcClientUSubscription
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more