Struct Client

pub struct Client {
    pub socket: Arc<Mutex<WebSocket<MaybeTlsStream<TcpStream>>>>,
    pub request_id: Arc<Mutex<u64>>,
    pub routing_id: Arc<Mutex<u64>>,
    pub events: Arc<Mutex<Vec<Arc<Mutex<(u64, Events)>>>>>,
}

Fields

socket: Arc<Mutex<WebSocket<MaybeTlsStream<TcpStream>>>>

request_id: Arc<Mutex<u64>>

routing_id: Arc<Mutex<u64>>

events: Arc<Mutex<Vec<Arc<Mutex<(u64, Events)>>>>>

Implementations

impl Client

pub fn connect<U: ToString, P: ToString>( request: WampRequest<U, P>, ) -> Result<(Client, Response<Option<Vec<u8>>>), Error>

pub fn on(&self, routing_id: u64, event: Events)

pub fn send<T: WampMessage + TryInto<Message>>( &self, message: T, ) -> Result<(), Error>

where Error: From<<T as TryInto<Message>>::Error>,

pub fn new_routing_id(&self) -> u64

pub fn new_request_id(&self) -> u64

pub fn remove_callbacks(&self, routing_ids: Vec<u64>)

pub fn event_loop(&mut self) -> Result<(), Error>

pub fn read_then_run_event( &mut self, ) -> Result<Option<(Messages, JoinHandle<()>)>, Error>

pub fn run_events( &mut self, message: Messages, ) -> Result<(Messages, JoinHandle<()>), Error>

pub fn read(&mut self) -> Result<Option<Messages>, Error>

Read

Read a frame from tungstenite and convert to WAMP messages.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl From<&Client> for Client

fn from(value: &Client) -> Self

Converts to this type from the input type.

impl From<&mut Client> for Client

fn from(value: &mut Client) -> Self

Converts to this type from the input type.