Struct ump_ng::Server

pub struct Server<P, 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<P, S, R, E> Server<P, S, R, E>

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

pub fn wait(&self) -> Result<MsgType<P, S, 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.

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

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

pub async fn async_wait(&self) -> Result<MsgType<P, S, 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.