Struct tungstenite::protocol::WebSocketContext[][src]

pub struct WebSocketContext { /* fields omitted */ }

A context for managing WebSocket stream.

Implementations

impl WebSocketContext[src]

pub fn new(role: Role, config: Option<WebSocketConfig>) -> Self[src]

Create a WebSocket context that manages a post-handshake stream.

pub fn from_partially_read(
    part: Vec<u8>,
    role: Role,
    config: Option<WebSocketConfig>
) -> Self
[src]

Create a WebSocket context that manages an post-handshake stream.

pub fn set_config(&mut self, set_func: impl FnOnce(&mut WebSocketConfig))[src]

Change the configuration.

pub fn can_read(&self) -> bool[src]

Check if it is possible to read messages.

Reading is impossible after receiving Message::Close. It is still possible after sending close frame since the peer still may send some data before confirming close.

pub fn can_write(&self) -> bool[src]

Check if it is possible to write messages.

Writing gets impossible immediately after sending or receiving Message::Close.

pub fn read_message<Stream>(&mut self, stream: &mut Stream) -> Result<Message> where
    Stream: Read + Write
[src]

Read a message from the provided stream, if possible.

This function sends pong and close responses automatically. However, it never blocks on write.

pub fn write_message<Stream>(
    &mut self,
    stream: &mut Stream,
    message: Message
) -> Result<()> where
    Stream: Read + Write
[src]

Send a message to the provided stream, if possible.

WebSocket will buffer a configurable number of messages at a time, except to reply to Ping and Close requests. If the WebSocket’s send queue is full, SendQueueFull will be returned along with the passed message. Otherwise, the message is queued and Ok(()) is returned.

Note that only the last pong frame is stored to be sent, and only the most recent pong frame is sent if multiple pong frames are queued.

pub fn write_pending<Stream>(&mut self, stream: &mut Stream) -> Result<()> where
    Stream: Read + Write
[src]

Flush the pending send queue.

pub fn close<Stream>(
    &mut self,
    stream: &mut Stream,
    code: Option<CloseFrame<'_>>
) -> Result<()> where
    Stream: Read + Write
[src]

Close the connection.

This function guarantees that the close frame will be queued. There is no need to call it again. Calling this function is the same as calling write(Message::Close(..)).

Trait Implementations

impl Debug for WebSocketContext[src]

Auto Trait Implementations

impl RefUnwindSafe for WebSocketContext

impl Send for WebSocketContext

impl Sync for WebSocketContext

impl Unpin for WebSocketContext

impl UnwindSafe for WebSocketContext

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> Same<T> for T[src]

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 
[src]