Struct DatagramFlow 

pub struct DatagramFlow { /* private fields */ }

Combination of DatagramIncoming and DatagramOutgoing

Implementations

impl DatagramFlow

pub fn new(local_max_datagram_frame_size: u64, tx_wakers: ArcSendWakers) -> Self

Creates a new instance of DatagramFlow.

This method takes local protocol parameter max_datagram_frame_size, the local’s transport parameter max_datagram_frame_size limits the size of the datagram frames that peer can send.

pub fn try_load_data_into<P>(&self, packet: &mut P) -> Result<(), Signals>

where P: BufMut + ?Sized, (DatagramFrame, Bytes): Package<P>,

pub fn reader(&self) -> Result<DatagramReader>

Create a new unique instance of DatagramReader.

Return an error if the connection is closing or already closed, or datagram is disenabled by local.

See DatagramIncoming::new_reader for more details.

pub fn writer(&self, max_datagram_frame_size: u64) -> Result<DatagramWriter>

Create a new instance of DatagramWriter.

Return an error if the connection is closing or already closed, or datagram is disenabled by peer(max_datagram_frame_size is 0)

See DatagramOutgoing::new_writer for more details.

pub fn on_conn_error(&self, error: &Error)

See DatagramOutgoing::on_conn_error and DatagramIncoming::on_conn_error for more details.

Trait Implementations

impl Clone for DatagramFlow

fn clone(&self) -> DatagramFlow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DatagramFlow

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

Formats the value using the given formatter.

impl ReceiveFrame<(DatagramFrame, Bytes)> for DatagramFlow

See DatagramIncoming::recv_datagram for more details.

type Output = ()

fn recv_frame( &self, (frame, body): (DatagramFrame, Bytes), ) -> Result<Self::Output, Error>

Receive the frames from the peer