async fn rpc_func_runner(
    ctl_channel: UnboundedSender<Request<'_>>,
    request: WampId,
    rpc_func: RpcFuture<'_>,
) -> Result<(), WampError> {
    // Run the RPC func
    let res = rpc_func.await;

    // Send the result
    match ctl_channel.send(Request::InvocationResult { request, res }) {
        Ok(_) => Ok(()),
        Err(_) => Err(From::from("Event loop has died !".to_string())),
    }
}
/// Runs the RPC function and forwards the result
Runs the RPC function and forwards the result
Runs the RPC function and forwards the result
async fn rpc_func_runner(
    ctl_channel: UnboundedSender<Request<'_>>,
    request: WampId,
    rpc_func: RpcFuture<'_>,
) -> Result<(), WampError> {
    // Run the RPC func
    let res = rpc_func.await;
    // Send the result
    match ctl_channel.send(Request::InvocationResult { request, res }) {
        Ok(_) => Ok(()),
        Err(_) => Err(From::from("Event loop has died !".to_string())),
    }
}
async fn rpc_func_runner ( ctl_channel : UnboundedSender < Request < ' _ > > , request : WampId , rpc_func : RpcFuture < ' _ > , ) -> Result < ( ) , WampError > { // Run the RPC func let res = rpc_func . await ; // Send the result match ctl_channel . send ( Request :: InvocationResult { request , res } ) { Ok ( _ ) => Ok ( ( ) ) , Err ( _ ) => Err ( From :: from ( " " . to_string ( ) ) ) , } }
Runs the RPC function and forwards the result
Runs the RPC function and forwards the result
ctl_channel
UnboundedSender<Request<'_>>
request
WampId
rpc_func
RpcFuture<'_>