async fn handle_register(
peer_addr: SocketAddr,
register: Register<'_>,
source: &mut Option<InputSourceHandle<InputMessage>>,
global: &Global,
priority_guard: &mut Option<PriorityGuard>,
) -> Result<(), FlatApiError>async fn handle_register(
peer_addr: SocketAddr,
register: Register<'_>,
source: &mut Option<InputSourceHandle<InputMessage>>,
global: &Global,
priority_guard: &mut Option<PriorityGuard>,
) -> Result<(), FlatApiError>