pub struct Receiver<T> { /* private fields */ }
Expand description

The receiving half of a connection.

Implementations§

source§

impl<T: AsyncRead + AsyncWrite + Unpin> Receiver<T>

source

pub async fn receive( &mut self, message: &mut Vec<u8> ) -> Result<Incoming<'_>, Error>

Receive the next websocket message.

The received frames forming the complete message will be appended to the given message argument. The returned Incoming value describes the type of data that was received, e.g. binary or textual data.

Interleaved PONG frames are returned immediately as Data::Pong values. If PONGs are not expected or uninteresting, Receiver::receive_data may be used instead which skips over PONGs and considers only application payload data.

source

pub async fn receive_data( &mut self, message: &mut Vec<u8> ) -> Result<Data, Error>

Receive the next websocket message, skipping over control frames.

Trait Implementations§

source§

impl<T: Debug> Debug for Receiver<T>

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<T> !RefUnwindSafe for Receiver<T>

§

impl<T> Send for Receiver<T>where T: Send,

§

impl<T> Sync for Receiver<T>where T: Send,

§

impl<T> Unpin for Receiver<T>

§

impl<T> !UnwindSafe for Receiver<T>

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> Same<T> for T

§

type Output = T

Should always be Self
source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

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

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

source§

fn vzip(self) -> V