Struct WebsocketTransport 

pub struct WebsocketTransport { /* private fields */ }

Trait Implementations

impl Debug for WebsocketTransport

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

Formats the value using the given formatter.

impl Transport for WebsocketTransport

type Acceptor = Listener

type RawStream = Stream

type Stream = WebsocketStream

fn new(config: &TransportConfig) -> Result<Self>

fn hint(conn: &Self::Stream, opt: SocketOpts)

Provide the transport with socket options, which can be handled at the need of the transport

fn as_raw_fd(conn: &Self::Stream) -> RawFd

Get the stream id, which is used to identify the transport layer

fn bind<'life0, 'async_trait>( &'life0 self, addr: NamedSocketAddr, ) -> Pin<Box<dyn Future<Output = Result<Self::Acceptor>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn accept<'life0, 'life1, 'async_trait>( &'life0 self, a: &'life1 Self::Acceptor, ) -> Pin<Box<dyn Future<Output = Result<(Self::RawStream, SocketAddr)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

accept must be cancel safe

fn handshake<'life0, 'async_trait>( &'life0 self, conn: Self::RawStream, ) -> Pin<Box<dyn Future<Output = Result<Self::Stream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn connect<'life0, 'life1, 'async_trait>( &'life0 self, addr: &'life1 AddrMaybeCached, ) -> Pin<Box<dyn Future<Output = Result<Self::Stream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_header(&self, name: &str) -> Option<String>