Struct WebSocketConn 

pub struct WebSocketConn { /* private fields */ }

A struct that represents an specific websocket connection.

This combines a websocket message stream with the request metadata and state of the trillium::Conn it was upgraded from.

The WebSocketConn implements Stream<Item=Result<Message, Error>>, and can be polled with StreamExt::next

Implementations

impl WebSocketConn

pub fn take_inbound_stream( &mut self, ) -> Option<impl Stream<Item = Result<Message, Error>> + use<>>

👎Deprecated:

a WebSocketConn is itself the stream of inbound messages; poll it directly

Take the inbound message stream from this conn.

The conn keeps sending, and yields no inbound messages of its own afterwards. Returns None if the stream was already taken.

pub fn inbound_stream( &mut self, ) -> Option<impl Stream<Item = Result<Message, Error>> + '_>

👎Deprecated:

a WebSocketConn is itself the stream of inbound messages; poll it directly

Borrow the inbound message stream from this conn, unless it was taken with take_inbound_stream.

impl WebSocketConn

pub async fn send_string(&mut self, string: String) -> Result<()>

send a Message::Text variant

pub async fn send_bytes(&mut self, bin: Vec<u8>) -> Result<()>

send a Message::Binary variant

pub async fn send_json(&mut self, json: &impl Serialize) -> Result<()>

send a Message::Text that contains json note that json messages are not actually part of the websocket specification

pub async fn send(&mut self, message: Message) -> Result<()>

Sends a Message to the client and flushes it to the socket

When sending many messages in quick succession, feed coalesces them into fewer socket writes.

pub async fn feed(&mut self, message: Message) -> Result<()>

Enqueues a Message without immediately writing it to the socket

The message is encoded into an internal write buffer. The buffer is written out when it fills, when this conn is next polled for an inbound message and none is immediately available, or on flush or send. If you feed a message and then await anything other than this conn, call flush first.

pub async fn flush(&mut self) -> Result<()>

Writes any buffered outbound messages to the socket

pub fn swansong(&self) -> Swansong

retrieve a clone of the server’s Swansong

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

close the websocket connection gracefully

If the peer has already sent a close frame, this sends the reply that completes the close handshake.

pub fn headers(&self) -> &Headers

retrieve the request headers for this conn

pub fn peer_ip(&self) -> Option<IpAddr>

retrieves the peer ip for this conn, if available

pub fn set_peer_ip(&mut self, peer_ip: Option<IpAddr>) -> &mut Self

Sets the peer ip for this conn

pub fn path(&self) -> &str

retrieves the path part of the request url, up to and excluding any query component

pub fn querystring(&self) -> &str

Retrieves the query component of the path, excluding ?. Returns an empty string if there is no query component.

pub fn method(&self) -> Method

retrieve the request method for this conn

pub fn state<T: Send + Sync + 'static>(&self) -> Option<&T>

retrieve state from the state set that has been accumulated by trillium handlers run on the trillium::Conn before it became a websocket. see trillium::Conn::state for more information

pub fn state_mut<T: Send + Sync + 'static>(&mut self) -> Option<&mut T>

retrieve a mutable borrow of the state from the state set

pub fn insert_state<T: Send + Sync + 'static>(&mut self, state: T) -> Option<T>

inserts new state

returns the previously set state of the same type, if any existed

pub fn state_entry<T: Send + Sync + 'static>(&mut self) -> Entry<'_, T>

Returns an Entry for the state typeset that can be used with functions like Entry::or_insert, Entry::or_insert_with, Entry::and_modify, and others.

pub fn take_state<T: Send + Sync + 'static>(&mut self) -> Option<T>

take some type T out of the state set that has been accumulated by trillium handlers run on the trillium::Conn before it became a websocket. see trillium::Conn::take_state for more information

Trait Implementations

impl AsMut<TypeSet> for WebSocketConn

fn as_mut(&mut self) -> &mut TypeSet

Converts this type into a mutable reference of the (usually inferred) input type.

impl AsRef<TypeSet> for WebSocketConn

fn as_ref(&self) -> &TypeSet

Converts this type into a shared reference of the (usually inferred) input type.

impl Debug for WebSocketConn

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Stream for WebSocketConn

type Item = Result<Message, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.