Struct websocket_lite::ClientBuilder

pub struct ClientBuilder { /* fields omitted */ }

Establishes a WebSocket connection.

ws://... and wss://... URLs are supported.

Methods

impl ClientBuilder

pub fn new(url: &str) -> Result<Self, ParseError>

Creates a ClientBuilder that connects to a given WebSocket URL.

This method returns an Err result if URL parsing fails.

pub fn from_url(url: Url) -> Self

Creates a ClientBuilder that connects to a given WebSocket URL.

This method never fails as the URL has already been parsed.

pub fn async_connect_insecure(
    self
) -> impl Future<Item = AsyncClient<TcpStream>, Error = Error>

Establishes a connection to the WebSocket server.

wss://... URLs are not supported by this method. Use async_connect if you need to be able to handle both ws://... and wss://... URLs.

pub fn connect_insecure(self) -> Result<Client<TcpStream>>

Establishes a connection to the WebSocket server.

wss://... URLs are not supported by this method. Use connect if you need to be able to handle both ws://... and wss://... URLs.

pub fn async_connect(
    self
) -> impl Future<Item = AsyncClient<Box<dyn AsyncNetworkStream + Sync + Send + 'static>>, Error = Error>

Establishes a connection to the WebSocket server.

pub fn connect(
    self
) -> Result<Client<Box<dyn NetworkStream + Sync + Send + 'static>>>

Establishes a connection to the WebSocket server.

pub fn async_connect_on<S: AsyncRead + AsyncWrite>(
    self,
    stream: S
) -> impl Future<Item = AsyncClient<S>, Error = Error>

Takes over an already established stream and uses it to send and receive WebSocket messages.

This method assumes that the TLS connection has already been established, if needed. It sends an HTTP Connection: Upgrade request and waits for an HTTP OK response before proceeding.

pub fn connect_on<S: Read + Write>(self, stream: S) -> Result<Client<S>>

Takes over an already established stream and uses it to send and receive WebSocket messages.

This method assumes that the TLS connection has already been established, if needed. It sends an HTTP Connection: Upgrade request and waits for an HTTP OK response before proceeding.