Struct TypedSocket

pub struct TypedSocket<T: ChannelMessage> {
    pub remote_handshake: Handshake,
    /* private fields */
}

Fields

remote_handshake: Handshake

Implementations

impl<T: ChannelMessage> TypedSocket<T>

pub fn send(&mut self, message: T) -> Result<(), PlaneClientError>

pub async fn recv(&mut self) -> Option<T::Reply>

pub fn sender<A, F>(&self, transform: F) -> TypedSocketSender<A>

where F: Fn(A) -> T + 'static + Send + Sync,

pub async fn close(&mut self)