Struct QueuedClient

pub struct QueuedClient<S: Read + Write + Source> { /* private fields */ }

Client with a queue of requests.

The client can be used with crates like popol or with mio if feature async-mio is enabled.

When the output is ready, a next event can be sent.

Implementations

impl<S: Read + Write + Source> QueuedClient<S>

pub fn new(client: Client<S>) -> Self

New asynchronous client build on top of a synchronous client.

pub fn push(&mut self, request: Request)

Push a new request in the queue.

pub fn pop(&mut self) -> Option<Request>

Pop the last request in the queue.

pub fn last(&self) -> Option<&Request>

Last request in the queue.

pub fn has_next(&self) -> bool

Return true if there is a pending request.

pub fn send_next(&mut self) -> ClientResult<bool>

Write one pending request if any.

Instance of mio::Poll generates a writable event only once until the socket returns WouldBlock. This error is mapped to ClientError::NotReady.

pub fn receive_next(&mut self) -> ClientResult<Response>

Receive one response.

Must be called each time a readable event is returned by mio::Poll.