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