Struct svc_agent::EventSubscription

pub struct EventSubscription<'a> { /* private fields */ }

Implementations

impl<'a> EventSubscription<'a>

pub fn new(source: Source<'a>) -> Self

Builds an EventSubscription.

Arguments

• source – events source.

Example

let account_id = AccountId::new("service_name", "svc.example.org");
let source = Source::Broadcast(&account_id, "v1", "rooms/+/events");
let subscription = EventSubscription::new(source);

Trait Implementations

impl<'a> SubscriptionTopic for EventSubscription<'a>

fn subscription_topic<A>( &self, _me: &A, _me_version: &str ) -> Result<String, Error>where A: Addressable,

Returns a topic to subscribe to as string.