Struct Server

pub struct Server { /* private fields */ }

The server struct. This is consumed when run, so you will typically not hold onto this for longer periods of time.

Implementations

impl Server

pub fn subscriptions(&self) -> Arc<SubscriptionCache>

Get a reference to the SubscriptionCache containing all subscriptions on the server.

pub async fn run_with(self, listener: TcpListener) -> Result<(), String>

Run the server using a given TCP listener. Note that the configured TCP endpoint is still used to create the endpoint descriptions, you must properly set host and port even when using this.

This is useful for testing, as you can bind a TcpListener to port 0 auto-assign a port.

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

Run the server. The provided token can be used to stop the server gracefully.