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 input_source(&self) -> &S

Input source.

pub fn output_source(&self) -> &S

Output source.

pub fn register( &mut self, poll: &Poll, input_token: Token, output_token: Token, ) -> Result<()>

Register 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 has_next(&self) -> bool

Return true if there is a pending request.

pub fn has_data_next(&self) -> bool

Return true if there is a pending request to send data.

After a Speak has been sent, when the client receives OK_RECEIVING_DATA, the next command must be Request::SendLine or Request::SendLines.

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

Next request in the queue.

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

Last request in the queue.

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.

Trait Implementations

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

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.