Struct hrpc::client::Socket

pub struct Socket<Req, Resp> where
    Req: Message,
    Resp: Message + Default,  { /* fields omitted */ }

A websocket, wrapped for ease of use with protobuf messages.

Implementations

impl<Req, Resp> Socket<Req, Resp> where
    Req: Message + 'static,
    Resp: Message + Default + 'static, 

pub async fn receive_message(&self) -> ClientResult<Resp>

Receive a message from the socket.

Returns a connection closed error if the socket is closed. This will block until getting a message if the socket is not closed.

pub async fn send_message(&self, req: Req) -> ClientResult<()>

Send a message over the socket.

This will block if the inner send buffer is filled.

pub fn is_closed(&self) -> bool

Return whether the socket is closed or not.

pub async fn close(&self)

Close the socket.

Trait Implementations

impl<Req: Clone, Resp: Clone> Clone for Socket<Req, Resp> where
    Req: Message,
    Resp: Message + Default, 

fn clone(&self) -> Socket<Req, Resp>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Req: Debug, Resp: Debug> Debug for Socket<Req, Resp> where
    Req: Message,
    Resp: Message + Default, 

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.