Trait runng::asyncio::reply_stream::AsyncReply

pub trait AsyncReply {
    fn receive(&mut self) -> Option<Receiver<Result<NngMsg>>>;
    fn reply(&mut self, msg: NngMsg) -> Receiver<Result<()>>;
}

Trait for asynchronous contexts that can receive a request and then send a reply.

Required methods

fn receive(&mut self) -> Option<Receiver<Result<NngMsg>>>

Asynchronously receive a request.

fn reply(&mut self, msg: NngMsg) -> Receiver<Result<()>>

Asynchronously reply to previously received request.

Loading content...

Implementors

impl AsyncReply for ReplyStreamHandle

fn receive(&mut self) -> Option<Receiver<Result<NngMsg>>>

fn reply(&mut self, msg: NngMsg) -> Receiver<Result<()>>

Loading content...