Enum OwnedMessage 

pub enum OwnedMessage {
    Text(String),
    Binary(Vec<u8>),
    Ping(Vec<u8>),
    Pong(Vec<u8>),
    Close(OwnedCloseFrame),
}

An owned WebSocket message, detached from reader buffers.

Variants

Text(String)

UTF-8 text message.

Binary(Vec<u8>)

Binary message.

Ping(Vec<u8>)

Ping control frame.

Pong(Vec<u8>)

Pong control frame.

Close(OwnedCloseFrame)

Connection close.

Implementations

impl OwnedMessage

pub fn as_bytes(&self) -> &[u8]

Payload as bytes, regardless of message type.

• Text → UTF-8 bytes
• Binary / Ping / Pong → raw bytes
• Close → reason string as bytes (excludes the 2-byte status code)

pub fn to_bytes(self) -> Bytes

Convert to bytes::Bytes. Zero-copy — takes ownership of the underlying Vec/String allocation without copying.

let msg = ws.recv()?.unwrap().into_owned();
let shared: Bytes = msg.to_bytes();
tx.send(shared)?;  // Send + Clone, cheap to share

Trait Implementations

impl Clone for OwnedMessage

fn clone(&self) -> OwnedMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OwnedMessage

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

Formats the value using the given formatter.

impl<S: WireStream + Unpin> Sink<OwnedMessage> for WsStream<S>

type Error = Error

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send( self: Pin<&mut Self>, item: OwnedMessage, ) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.