Struct Server

pub struct Server<Listener, Service> { /* private fields */ }

A server.

The server listens for incoming connections and handles method calls using a service.

Implementations

impl<Listener, Service> Server<Listener, Service>

where Listener: Listener, Service: Service,

pub fn new(listener: Listener, service: Service) -> Self

Create a new server that serves service to incomming connections from listener.

pub async fn run(self) -> Result<()>

Run the server.

Caveats

Due to a bug in the rust compiler, the future returned by this method can not be treated as Send, even if all the specific types involved are Send. A major consequence of this fact unfortunately, is that it can not be spawned in a task of a multi-threaded runtime. For example, you can not currently do tokio::spawn(server.run()).

Fortunately, there are easy workarounds for this. You can either:

• Use a thread-local runtime (for example tokio::runtime::LocalRuntime or tokio::task::LocalSet) to run the server in a local task, perhaps in a seprate thread.
• Use some common API to run multiple futures at once, such as futures::select! or tokio::select!.

Most importantly, this is most likely a temporary issue and will be fixed in the future. 😊

Trait Implementations

impl<Listener: Debug, Service: Debug> Debug for Server<Listener, Service>

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

Formats the value using the given formatter.