Struct svc_agent::EventSubscription

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

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.