Struct Transport 

pub(crate) struct Transport {
    write: SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>,
    read: SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>,
}

WebSocket transport that frames Centrifugo protobuf commands and replies.

Fields

write: SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>

read: SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>

Implementations

impl Transport

pub(crate) async fn connect(url: &str) -> Result<Self, Error>

pub(crate) async fn send_command( &mut self, cmd: Command, ) -> Result<Reply, Error>

pub(crate) async fn send_raw(&mut self, data: Vec<u8>) -> Result<(), Error>

pub(crate) async fn read_message(&mut self) -> Result<Reply, Error>

pub(crate) async fn close(&mut self)

Trait Implementations

impl Debug for Transport

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

Formats the value using the given formatter.