Trait runng::asyncio::pull_stream::AsyncPull

pub trait AsyncPull {
    fn receive(&mut self) -> Option<Receiver<Result<NngMsg>>>;
}

Trait for asynchronous contexts that can receive a stream of messages.

Required methods

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

Asynchronously receive a stream of messages.

Loading content...

Implementors

impl AsyncPull for PairStreamHandle

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

impl AsyncPull for PullAsyncStream

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

impl AsyncPull for SubscribeAsyncStream

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

Loading content...