Struct LocalServer 

pub struct LocalServer<H, T: LocalTransport> { /* private fields */ }

Single-threaded server instance for LocalTransport backends.

LocalServer::run must be polled inside a Tokio LocalSet (e.g. from inside tokio_uring::start(async { server.run().await })). Polling it from a context without a LocalSet will fail at the first spawn_local call.

Implementations

impl<H, T> LocalServer<H, T>

where H: MessageHandler + 'static, T: LocalTransport, T::Connection: 'static,

pub async fn run(&mut self) -> Result<(), ServerError>

Runs the server, accepting connections and processing messages.

Errors

Returns ServerError if the listener fails to bind or the accept loop encounters an unrecoverable error.

Panics

Panics indirectly via tokio::task::spawn_local if called outside a LocalSet context. See the type-level docs.