Struct WsConnection 

pub struct WsConnection<F> { /* private fields */ }

Implementations

impl<F> WsConnection<F>

pub fn codec(&self) -> &Codec

Get codec reference

pub fn response(&self) -> &ClientResponse

Get reference to response

impl<F> WsConnection<F>

pub fn sink(&self) -> WsSink

Get ws sink

pub fn into_inner(self) -> (Io<F>, Codec, ClientResponse)

Consumes the WsConnection, returning it’as underlying I/O stream object and response.

impl WsConnection<Sealed>

pub fn receiver(self) -> Receiver<Result<Frame, WsError<()>>>

Start client websockets with SinkService and mpsc::Receiver<Frame>

pub async fn start<T, U>(self, service: U) -> Result<(), WsError<T::Error>>

where T: Service<Frame, Response = Option<Message>> + 'static, U: IntoService<T, Frame>,

Start client websockets service.

impl<F: Filter> WsConnection<F>

pub fn seal(self) -> WsConnection<Sealed>

Convert I/O stream to boxed stream

pub fn into_transport(self) -> Io<Layer<WsTransport, F>>

Convert to ws stream to plain io stream

Trait Implementations

impl<F> Debug for WsConnection<F>

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

Formats the value using the given formatter.