Struct Consumer 

pub struct Consumer<T>
where
    T: Transport + 'static,
{ /* private fields */ }

Subscription consumer

Implementations

impl<T> Consumer<T>

where T: Transport + 'static,

pub fn new( transport: T, prefer_polling: bool, context: <T::Spec as Spec>::Context, ) -> Arc<Self>

Creates a new instance

pub fn subscribe<I>( self: &Arc<Self>, request: I, ) -> Result<RemoteActiveConsumer<T>, Error>

where I: SubscriptionRequest<Topic = <T::Spec as Spec>::Topic, SubscriptionId = <T::Spec as Spec>::SubscriptionId>,

Creates a subscription

The subscriptions have two parts:

1. Will create the subscription to the remote Pubsub service, Any events will be moved to the internal pubsub

2. The internal subscription to the inner Pubsub. Because all subscriptions are going the transport, once events matches subscriptions, the inner_pubsub will receive the message and broadcasat the event.

Trait Implementations

impl<T> Drop for Consumer<T>

where T: Transport + 'static,

fn drop(&mut self)

Executes the destructor for this type.