[−][src]Trait nsq_client::Subscribe

pub trait Subscribe where
    Self: Actor,
    Self::Context: AsyncContext<Self>, {
    fn subscribe<M: NsqMsg>(
        &self, 
        ctx: &mut Self::Context, 
        addr: Arc<Addr<Connection>>
    )
    where
        Self: Handler<M>,
        Self::Context: ToEnvelope<Self, M>,
    { ... }
}

Provided methods

fn subscribe<M: NsqMsg>(
    &self,
    ctx: &mut Self::Context,
    addr: Arc<Addr<Connection>>
) where
    Self: Handler<M>,
    Self::Context: ToEnvelope<Self, M>, 

Loading content...

Implementors

impl<A> Subscribe for A where
    A: Actor,
    Self::Context: AsyncContext<A>, [src]

fn subscribe<M: NsqMsg>(
    &self,
    ctx: &mut Self::Context,
    addr: Arc<Addr<Connection>>
) where
    Self: Handler<M>,
    Self::Context: ToEnvelope<Self, M>, [src]

Loading content...