Struct Subscriber

pub struct Subscriber<T>
where
    T: UOwnedTransport + ?Sized,
{ /* private fields */ }

Subscriber implemented over an owned native-frame transport.

Role: the up-L2 Subscriber for the owned family. Like its UTransport-family sibling, subscription is a service interaction: it requires a USubscription client and informs the uSubscription service before registering the local listener, per the uProtocol specification.

Implementations

impl<T> Subscriber<T>

where T: UOwnedTransport + ?Sized,

pub fn new(transport: Arc<T>, usubscription: Arc<dyn USubscription>) -> Self

Creates a subscriber over an owned-frame transport and a uSubscription service client.

pub async fn subscribe( &self, topic: &UUri, handler: Arc<dyn UListener>, subscription_change_handler: Option<Arc<dyn SubscriptionChangeHandler>>, ) -> Result<(), RegistrationError>

Subscribes to a topic: informs the uSubscription service first, then registers the owned-frame listener on success.

pub async fn unsubscribe( &self, topic: &UUri, handler: Arc<dyn UListener>, ) -> Result<(), RegistrationError>

Unsubscribes from a topic: informs the uSubscription service, then unregisters the owned-frame listener.

Trait Implementations

impl<T> Debug for Subscriber<T>

where T: UOwnedTransport + ?Sized,

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

Formats the value using the given formatter.

impl<T> Subscriber for Subscriber<T>

where T: UOwnedTransport + ?Sized,

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 UUri, handler: Arc<dyn UListener>, subscription_change_handler: Option<Arc<dyn SubscriptionChangeHandler>>, ) -> Pin<Box<dyn Future<Output = Result<(), RegistrationError>> + Send + 'async_trait>>

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

Registers a handler to invoke for messages that have been published to a given topic.

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

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

Deregisters a previously registered handler.