Struct FastWsReader 

pub struct FastWsReader<S: AsyncRead + Unpin + Send> { /* private fields */ }

fastwebsockets read half adapter.

Wraps FragmentCollectorRead<ReadHalf<S>> for safe handling of any unexpected WS fragmentation (negligible overhead in the common non- fragmented case: one branch per frame, no allocation).

auto_pong and auto_close are disabled. PING and Close frames are surfaced as WsMessage::Ping and WsMessage::Close so the mux reader handles them through the existing command path (SendWsPong, break loop). Pong, Text, and Continuation frames are absorbed in the read loop; the mux never sees them.

Implementations

impl<S: AsyncRead + Unpin + Send> FastWsReader<S>

pub const fn new(ws: FragmentCollectorRead<S>) -> Self

Trait Implementations

impl<S: AsyncRead + Unpin + Send> WsFrameReader for FastWsReader<S>

async fn read_message(&mut self) -> Option<Result<WsMessage, TransportError>>

Read the next actionable WebSocket message.