pub trait Receiver {
type F: DataFrame;
type M: Message;
fn recv_dataframe<R>(
&mut self,
reader: &mut R
) -> Result<Self::F, WebSocketError>
where
R: Read;
fn recv_message_dataframes<R>(
&mut self,
reader: &mut R
) -> Result<Vec<Self::F, Global>, WebSocketError>
where
R: Read;
fn incoming_dataframes<R>(
&'a mut self,
reader: &'a mut R
) -> DataFrameIterator<'a, Self, R>ⓘNotable traits for DataFrameIterator<'a, Recv, R>impl<'a, Recv, R> Iterator for DataFrameIterator<'a, Recv, R> where
Recv: 'a + Receiver,
R: Read, type Item = Result<<Recv as Receiver>::F, WebSocketError>;
where
R: Read,
{ ... }
fn recv_message<R>(
&mut self,
reader: &mut R
) -> Result<Self::M, WebSocketError>
where
R: Read,
{ ... }
fn incoming_messages<R>(
&'a mut self,
reader: &'a mut R
) -> MessageIterator<'a, Self, R>ⓘNotable traits for MessageIterator<'a, Recv, R>impl<'a, Recv, R> Iterator for MessageIterator<'a, Recv, R> where
Recv: 'a + Receiver,
R: Read, type Item = Result<<Recv as Receiver>::M, WebSocketError>;
where
R: Read,
{ ... }
}
Expand description
A trait for receiving data frames and messages.
Associated Types
Required methods
fn recv_dataframe<R>(
&mut self,
reader: &mut R
) -> Result<Self::F, WebSocketError> where
R: Read,
fn recv_dataframe<R>(
&mut self,
reader: &mut R
) -> Result<Self::F, WebSocketError> where
R: Read,
Reads a single data frame from this receiver.
fn recv_message_dataframes<R>(
&mut self,
reader: &mut R
) -> Result<Vec<Self::F, Global>, WebSocketError> where
R: Read,
fn recv_message_dataframes<R>(
&mut self,
reader: &mut R
) -> Result<Vec<Self::F, Global>, WebSocketError> where
R: Read,
Returns the data frames that constitute one message.
Provided methods
fn incoming_dataframes<R>(
&'a mut self,
reader: &'a mut R
) -> DataFrameIterator<'a, Self, R>ⓘNotable traits for DataFrameIterator<'a, Recv, R>impl<'a, Recv, R> Iterator for DataFrameIterator<'a, Recv, R> where
Recv: 'a + Receiver,
R: Read, type Item = Result<<Recv as Receiver>::F, WebSocketError>;
where
R: Read,
fn incoming_dataframes<R>(
&'a mut self,
reader: &'a mut R
) -> DataFrameIterator<'a, Self, R>ⓘNotable traits for DataFrameIterator<'a, Recv, R>impl<'a, Recv, R> Iterator for DataFrameIterator<'a, Recv, R> where
Recv: 'a + Receiver,
R: Read, type Item = Result<<Recv as Receiver>::F, WebSocketError>;
where
R: Read,
Recv: 'a + Receiver,
R: Read, type Item = Result<<Recv as Receiver>::F, WebSocketError>;
Returns an iterator over incoming data frames.
fn recv_message<R>(&mut self, reader: &mut R) -> Result<Self::M, WebSocketError> where
R: Read,
fn recv_message<R>(&mut self, reader: &mut R) -> Result<Self::M, WebSocketError> where
R: Read,
Reads a single message from this receiver.
fn incoming_messages<R>(
&'a mut self,
reader: &'a mut R
) -> MessageIterator<'a, Self, R>ⓘNotable traits for MessageIterator<'a, Recv, R>impl<'a, Recv, R> Iterator for MessageIterator<'a, Recv, R> where
Recv: 'a + Receiver,
R: Read, type Item = Result<<Recv as Receiver>::M, WebSocketError>;
where
R: Read,
fn incoming_messages<R>(
&'a mut self,
reader: &'a mut R
) -> MessageIterator<'a, Self, R>ⓘNotable traits for MessageIterator<'a, Recv, R>impl<'a, Recv, R> Iterator for MessageIterator<'a, Recv, R> where
Recv: 'a + Receiver,
R: Read, type Item = Result<<Recv as Receiver>::M, WebSocketError>;
where
R: Read,
Recv: 'a + Receiver,
R: Read, type Item = Result<<Recv as Receiver>::M, WebSocketError>;
Returns an iterator over incoming messages.