Function lunatic_distributed::distributed::server::handle_message
source · pub async fn handle_message<T, E>(
ctx: ServerCtx<T, E>,
send: &mut SendStream,
msg_id: u64,
msg: Request
)where
T: ProcessState + DistributedCtx<E> + ResourceLimiter + Send + Sync + 'static,
E: Environment + 'static,