Struct Server

pub struct Server<S, R, E>(/* private fields */);

Representation of a server object.

Each instantiation of a Server object represents an end-point which will be used to receive messages from connected Client objects.

Implementations

impl<S, R, E> Server<S, R, E>

where S: 'static + Send, R: 'static + Send, E: 'static + Send,

pub fn wait(&self) -> Result<(S, ReplyContext<R, E>), Error<E>>

Block and wait, indefinitely, for an incoming message from a Client.

Returns the message sent by the client and a reply context. The server must call ReplyContext::reply() on the reply context to pass a return value to the client.

Errors

Err(Error::ClientsDisappeared) indicates that the queue is empty and all the client end-points have been dropped.

pub fn try_pop(&self) -> Result<Option<(S, ReplyContext<R, E>)>, Error<E>>

Take next next message off queue or return None is queue is empty.

Errors

Error::ClientsDisappeared indicates that the queue is empty and all the client end-points have been dropped.

pub async fn async_wait(&self) -> Result<(S, ReplyContext<R, E>), Error<E>>

Same as Server::wait(), but for use in an async context.

pub fn was_empty(&self) -> bool

Returns a boolean indicating whether the queue is/was empty. This isn’t really useful unless used in very specific situations. It mostly exists for test cases.