Struct Framer

pub struct Framer<'a, TRng, TWebSocketType>
where
    TRng: RngCore,
    TWebSocketType: WebSocketType,
{ /* private fields */ }

Implementations

impl<'a, TRng> Framer<'a, TRng, Client>

where TRng: RngCore,

pub fn connect<E>( &mut self, stream: &mut impl Stream<E>, websocket_options: &WebSocketOptions<'_>, ) -> Result<Option<WebSocketSubProtocol>, FramerError<E>>

impl<'a, TRng> Framer<'a, TRng, Server>

where TRng: RngCore,

pub fn accept<E>( &mut self, stream: &mut impl Stream<E>, websocket_context: &WebSocketContext, ) -> Result<(), FramerError<E>>

impl<'a, TRng, TWebSocketType> Framer<'a, TRng, TWebSocketType>

where TRng: RngCore, TWebSocketType: WebSocketType,

pub fn new( read_buf: &'a mut [u8], read_cursor: &'a mut usize, write_buf: &'a mut [u8], websocket: &'a mut WebSocket<TRng, TWebSocketType>, ) -> Self

pub fn state(&self) -> WebSocketState

pub fn close<E>( &mut self, stream: &mut impl Stream<E>, close_status: WebSocketCloseStatusCode, status_description: Option<&str>, ) -> Result<(), FramerError<E>>

pub fn write<E>( &mut self, stream: &mut impl Stream<E>, message_type: WebSocketSendMessageType, end_of_message: bool, frame_buf: &[u8], ) -> Result<(), FramerError<E>>

pub fn read<'b, E>( &mut self, stream: &mut impl Stream<E>, frame_buf: &'b mut [u8], ) -> Result<ReadResult<'b>, FramerError<E>>