pub async fn call<T: AsRef<str>>(
        &self,
        uri: T,
        arguments: Option<WampArgs>,
        arguments_kw: Option<WampKwArgs>,
    ) -> Result<(Option<WampArgs>, Option<WampKwArgs>), WampError> {
        // Send the request
        let (res, result) = oneshot::channel();
        if let Err(e) = self.ctl_channel.send(Request::Call {
            uri: uri.as_ref().to_string(),
            options: WampDict::new(),
            arguments,
            arguments_kw,
            res,
        }) {
            return Err(From::from(format!(
                "Core never received our request : {}",
                e
            )));
        }

        // Wait for the result
        match result.await {
            Ok(r) => r,
            Err(e) => Err(From::from(format!(
                "Core never returned a response : {}",
                e
            ))),
        }
    }
/// Calls a registered RPC endpoint on the server
Calls a registered RPC endpoint on the server
Calls a registered RPC endpoint on the server
pub async fn call<T: AsRef<str>>(
        &self,
        uri: T,
        arguments: Option<WampArgs>,
        arguments_kw: Option<WampKwArgs>,
    ) -> Result<(Option<WampArgs>, Option<WampKwArgs>), WampError> {
        // Send the request
        let (res, result) = oneshot::channel();
        if let Err(e) = self.ctl_channel.send(Request::Call {
            uri: uri.as_ref().to_string(),
            options: WampDict::new(),
            arguments,
            arguments_kw,
            res,
        }) {
            return Err(From::from(format!(
                "Core never received our request : {}",
                e
            )));
        }
        // Wait for the result
        match result.await {
            Ok(r) => r,
            Err(e) => Err(From::from(format!(
                "Core never returned a response : {}",
                e
            ))),
        }
    }
pub async fn call < T : AsRef < str > > ( & self , uri : T , arguments : Option < WampArgs > , arguments_kw : Option < WampKwArgs > , ) -> Result < ( Option < WampArgs > , Option < WampKwArgs > ) , WampError > { // Send the request let ( res , result ) = oneshot :: channel ( ) ; if let Err ( e ) = self . ctl_channel . send ( Request :: Call { uri : uri . as_ref ( ) . to_string ( ) , options : WampDict :: new ( ) , arguments , arguments_kw , res , } ) { return Err ( From :: from ( format ! ( " " e ) ) ) ; } // Wait for the result match result . await { Ok ( r ) => r , Err ( e ) => Err ( From :: from ( format ! ( " " e ) ) ) , } }
Calls a registered RPC endpoint on the server
Calls a registered RPC endpoint on the server
&self
uri
T
arguments
Option<WampArgs>
arguments_kw
Option<WampKwArgs>