Struct Client 

pub struct Client { /* private fields */ }

Implementations

impl Client

pub fn new(transport: Arc<dyn Transport>, listen_once: bool) -> Self

pub async fn send_sync<Request: Serialize, Response: DeserializeOwned>( &self, event: &str, data: &mut Request, ) -> Result<Response, MsRsError>

pub async fn listen<Request, Response, Fut>( &self, event: &str, f: Box<dyn Fn(Request) -> Fut + Sync + Send + 'static>, ) -> Result<(), MsRsError>

where Fut: Future<Output = Result<Option<Response>, MsRsError>> + Send + 'static, Request: DeserializeOwned, Response: Serialize,

pub async fn send<Request: Serialize>( &self, event: &str, headers: Option<HashMap<String, String>>, data: Request, ) -> Result<(), MsRsError>