Struct WebSocketTransport 

pub struct WebSocketTransport { /* private fields */ }

A Transport backed by a tokio-tungstenite WebSocket stream.

Use WebSocketTransport::connect for the common case, or WebSocketTransport::from_stream when you need custom connection options (custom TLS configuration, additional headers, etc.).

Example

use ahp::{Client, ClientConfig};
use ahp_ws::WebSocketTransport;

let transport = WebSocketTransport::connect("ws://localhost:12345").await?;
let client = Client::connect(transport, ClientConfig::default()).await?;
client.initialize("demo".into(), vec!["0.1.0".into()], vec![]).await?;

Implementations

impl WebSocketTransport

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

Open a new WebSocket connection to url.

Both ws:// and wss:// schemes are accepted; the wss:// TLS backend is chosen at compile time by Cargo feature (see the crate docs), defaulting to rustls with OS-trust-store roots. The URL is parsed eagerly so malformed URLs surface as WebSocketTransportError::InvalidUrl before any network I/O.

pub fn from_stream(inner: WebSocketStream<MaybeTlsStream<TcpStream>>) -> Self

Wrap an already-connected WebSocket stream.

Use this when you need to drive the tokio-tungstenite handshake yourself — for custom TLS configuration, request headers, or to reuse an existing socket.

Trait Implementations

impl Transport for WebSocketTransport

async fn send(&mut self, msg: TransportMessage) -> Result<(), TransportError>

Send a single message.

async fn recv(&mut self) -> Result<Option<TransportMessage>, TransportError>

Receive the next inbound message.

async fn close(&mut self) -> Result<(), TransportError>

Close the transport and release any underlying resources.