Skip to main content

run_command_handler_server

Function run_command_handler_server 

Source
pub async fn run_command_handler_server<S, H>(
    domain: &str,
    default_port: u16,
    router: CommandHandlerRouter<S, H>,
) -> Result<(), Error>
where S: Default + Send + Sync + 'static, H: CommandHandlerDomainHandler<State = S> + Clone + 'static,
Expand description

Run a command handler service with the given router.

Supports both TCP and Unix domain socket (UDS) transport. UDS is used when UDS_BASE_PATH, SERVICE_NAME, and DOMAIN env vars are set.

§Example

use angzarr_client::{run_command_handler_server, CommandHandlerRouter};

#[tokio::main]
async fn main() {
    let router = CommandHandlerRouter::new("player", "player", PlayerHandler::new());

    run_command_handler_server("player", 50001, router).await;
}