Struct svc_agent::ResponseSubscription

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

Implementations

impl<'a> ResponseSubscription<'a>

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

Builds a ResponseSubscription.

Arguments

• source – responses source.

Example

let account_id = AccountId::new("service_name", "svc.example.org");
let subscription = RequestSubscription::new(Source::Unicast(&account_id));

Trait Implementations

impl<'a> SubscriptionTopic for ResponseSubscription<'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.