async fn handle_local_request(&mut self, req: Request<'a>) -> Status {
        // Forward the request the the implementor
        match req {
            Request::Shutdown => Status::Shutdown,
            Request::Join {
                uri,
                roles,
                agent_str,
                authentication_methods,
                authentication_id,
                on_challenge_handler,
                res,
            } => {
                send::join_realm(
                    self,
                    uri,
                    roles,
                    agent_str,
                    authentication_methods,
                    authentication_id,
                    on_challenge_handler,
                    res,
                )
                .await
            }
            Request::Leave { res } => send::leave_realm(self, res).await,
            Request::Subscribe { uri, res } => send::subscribe(self, uri, res).await,
            Request::Unsubscribe { sub_id, res } => send::unsubscribe(self, sub_id, res).await,
            Request::Publish {
                uri,
                options,
                arguments,
                arguments_kw,
                res,
            } => send::publish(self, uri, options, arguments, arguments_kw, res).await,
            Request::Register { uri, res, func_ptr } => {
                send::register(self, uri, res, func_ptr).await
            }
            Request::Unregister { rpc_id, res } => send::unregister(self, rpc_id, res).await,
            Request::InvocationResult { request, res } => {
                send::invoke_yield(self, request, res).await
            }
            Request::Call {
                uri,
                options,
                arguments,
                arguments_kw,
                res,
            } => send::call(self, uri, options, arguments, arguments_kw, res).await,
        }
    }
/// Handles the basic ways one can interact with the peer
Handles the basic ways one can interact with the peer
Handles the basic ways one can interact with the peer
async fn handle_local_request(&mut self, req: Request<'a>) -> Status {
        // Forward the request the the implementor
        match req {
            Request::Shutdown => Status::Shutdown,
            Request::Join {
                uri,
                roles,
                agent_str,
                authentication_methods,
                authentication_id,
                on_challenge_handler,
                res,
            } => {
                send::join_realm(
                    self,
                    uri,
                    roles,
                    agent_str,
                    authentication_methods,
                    authentication_id,
                    on_challenge_handler,
                    res,
                )
                .await
            }
            Request::Leave { res } => send::leave_realm(self, res).await,
            Request::Subscribe { uri, res } => send::subscribe(self, uri, res).await,
            Request::Unsubscribe { sub_id, res } => send::unsubscribe(self, sub_id, res).await,
            Request::Publish {
                uri,
                options,
                arguments,
                arguments_kw,
                res,
            } => send::publish(self, uri, options, arguments, arguments_kw, res).await,
            Request::Register { uri, res, func_ptr } => {
                send::register(self, uri, res, func_ptr).await
            }
            Request::Unregister { rpc_id, res } => send::unregister(self, rpc_id, res).await,
            Request::InvocationResult { request, res } => {
                send::invoke_yield(self, request, res).await
            }
            Request::Call {
                uri,
                options,
                arguments,
                arguments_kw,
                res,
            } => send::call(self, uri, options, arguments, arguments_kw, res).await,
        }
    }
async fn handle_local_request ( & mut self , req : Request < ' a > ) -> Status { // Forward the request the the implementor match req { Request :: Shutdown => Status :: Shutdown , Request :: Join { uri , roles , agent_str , authentication_methods , authentication_id , on_challenge_handler , res , } => { send :: join_realm ( self , uri , roles , agent_str , authentication_methods , authentication_id , on_challenge_handler , res , ) . await } Request :: Leave { res } => send :: leave_realm ( self , res ) . await , Request :: Subscribe { uri , res } => send :: subscribe ( self , uri , res ) . await , Request :: Unsubscribe { sub_id , res } => send :: unsubscribe ( self , sub_id , res ) . await , Request :: Publish { uri , options , arguments , arguments_kw , res , } => send :: publish ( self , uri , options , arguments , arguments_kw , res ) . await , Request :: Register { uri , res , func_ptr } => { send :: register ( self , uri , res , func_ptr ) . await } Request :: Unregister { rpc_id , res } => send :: unregister ( self , rpc_id , res ) . await , Request :: InvocationResult { request , res } => { send :: invoke_yield ( self , request , res ) . await } Request :: Call { uri , options , arguments , arguments_kw , res , } => send :: call ( self , uri , options , arguments , arguments_kw , res ) . await , } }
Handles the basic ways one can interact with the peer
Handles the basic ways one can interact with the peer
&mut self
req
Request<'a>