Struct WebSocketTransport 

pub struct WebSocketTransport { /* private fields */ }

Implementations

impl WebSocketTransport

pub fn new(url: String) -> Self

pub fn with_reconnect_config( url: String, _max_attempts: usize, _delay_ms: u32, ) -> Self

pub async fn connect(&self) -> Result<(), TransportError>

pub async fn disconnect(&self) -> Result<(), TransportError>

pub async fn send_binary(&self, _data: &[u8]) -> Result<(), TransportError>

pub async fn send_text(&self, _text: &str) -> Result<(), TransportError>

Trait Implementations

impl Clone for WebSocketTransport

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SyncTransport for WebSocketTransport

type Error = TransportError

fn send( &self, _data: &[u8], ) -> impl Future<Output = Result<(), Self::Error>> + Send

Send data to remote peers

fn receive( &self, ) -> impl Future<Output = Result<Vec<Vec<u8>>, Self::Error>> + Send

Receive data from remote peers

fn is_connected(&self) -> bool

Check if transport is connected