Trait little_stomper::destinations::Destinations

pub trait Destinations: Send + Clone {
    fn subscribe<T: BorrowedSubscriber>(
        &self, 
        destination: DestinationId, 
        sender_subscription_id: Option<SubscriptionId>, 
        client: T
    );
    fn unsubscribe<T: BorrowedSubscriber>(
        &self, 
        destination: DestinationId, 
        destination_subscription_id: SubscriptionId, 
        client: T
    );
    fn send<T: BorrowedSender>(
        &self, 
        destination: DestinationId, 
        message: InboundMessage, 
        sender: T
    );
}

Required methods

fn subscribe<T: BorrowedSubscriber>(
    &self,
    destination: DestinationId,
    sender_subscription_id: Option<SubscriptionId>,
    client: T
)

fn unsubscribe<T: BorrowedSubscriber>(
    &self,
    destination: DestinationId,
    destination_subscription_id: SubscriptionId,
    client: T
)

fn send<T: BorrowedSender>(
    &self,
    destination: DestinationId,
    message: InboundMessage,
    sender: T
)

Send a message to this destination and, by implication, all clients subscribed to it

Implementors

impl<D: DestinationType> Destinations for AsyncDestinations<D>

fn subscribe<T: BorrowedSubscriber>(
    &self,
    destination: DestinationId,
    subscriber_sub_id: Option<SubscriptionId>,
    client: T
)

fn send<T: BorrowedSender>(
    &self,
    destination: DestinationId,
    message: InboundMessage,
    sender: T
)

fn unsubscribe<T: BorrowedSubscriber>(
    &self,
    destination: DestinationId,
    subscription: SubscriptionId,
    subscriber: T
)