Crate reqwest_websocket

Provides wrappers for reqwest to enable WebSocket connections.

Example

// Extends the `reqwest::RequestBuilder` to allow WebSocket upgrades.
use reqwest_websocket::RequestBuilderExt;

// Creates a GET request, upgrades and sends it.
let response = Client::default()
    .get("wss://echo.websocket.org/")
    .upgrade() // Prepares the WebSocket upgrade.
    .send()
    .await?;

// Turns the response into a WebSocket stream.
let mut websocket = response.into_websocket().await?;

// The WebSocket implements `Sink<Message>`.
websocket.send(Message::Text("Hello, World".into())).await?;

// The WebSocket is also a `TryStream` over `Message`s.
while let Some(message) = websocket.try_next().await? {
    if let Message::Text(text) = message {
        println!("received: {text}")
    }
}

Structs

• UpgradeResponse
  The server’s response to the WebSocket upgrade request.
• UpgradedRequestBuilder
  Wrapper for a reqwest::RequestBuilder that performs the WebSocket handshake when sent.
• WebSocket
  A WebSocket connection. Implements futures_util::Stream and futures_util::Sink.

Enums

• CloseCode
  Status code used to indicate why an endpoint is closing the WebSocket connection.1
• Error
  Errors returned by reqwest_websocket.
• HandshakeErrorNon-WebAssembly
  Error during Websocket handshake.
• Message
  A WebSocket message, which can be a text string or binary data.

Traits

• RequestBuilderExt
  Trait that extends reqwest::RequestBuilder with an upgrade method.

Functions

• websocket
  Opens a WebSocket connection at the specified URL.