Struct nsqueue::consumer::Consumer
[−]
[src]
pub struct Consumer { /* fields omitted */ }Methods
impl Consumer[src]
fn connect(
addr: &SocketAddr,
handle: &Handle,
config: Config
) -> Box<Future<Item = Consumer, Error = Error>>
addr: &SocketAddr,
handle: &Handle,
config: Config
) -> Box<Future<Item = Consumer, Error = Error>>
Establish a connection and send protocol version.
fn subscribe(
&self,
topic: String,
channel: String
) -> Box<Future<Item = ResponseStream, Error = Error>>
&self,
topic: String,
channel: String
) -> Box<Future<Item = ResponseStream, Error = Error>>
fn fin(&self, message_id: String) -> Box<Future<Item = (), Error = Error>>
fn nop(&self) -> Box<Future<Item = (), Error = Error>>
Trait Implementations
impl Clone for Consumer[src]
fn clone(&self) -> Consumer
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)1.0.0
Performs copy-assignment from source. Read more