Enum libp2p_mplex::MaxBufferBehaviour[][src]

pub enum MaxBufferBehaviour {
    ResetStream,
    Block,
}

Behaviour when the maximum length of the buffer is reached.

Variants

ResetStream

Reset the substream whose frame buffer overflowed.

Note: If more than MplexConfig::set_max_buffer_size() frames are received in succession for a substream in the context of trying to read data from a different substream, the former substream may be reset before application code had a chance to read from the buffer. The max. buffer size needs to be sized appropriately when using this option to balance maximum resource usage and the probability of premature termination of a substream.

Block

No new message can be read from the underlying connection from any substream as long as the buffer for a single substream is full, i.e. application code is expected to read from the full buffer.

Note: To avoid blocking without making progress, application tasks should ensure that, when woken, always try to read (i.e. make progress) from every substream on which data is expected. This is imperative in general, as a woken task never knows for which substream it has been woken, but failure to do so with MaxBufferBehaviour::Block in particular may lead to stalled execution or spinning of a task without progress.

Trait Implementations

impl Clone for MaxBufferBehaviour[src]

impl Copy for MaxBufferBehaviour[src]

impl Debug for MaxBufferBehaviour[src]

impl Eq for MaxBufferBehaviour[src]

impl PartialEq<MaxBufferBehaviour> for MaxBufferBehaviour[src]

impl StructuralEq for MaxBufferBehaviour[src]

impl StructuralPartialEq for MaxBufferBehaviour[src]

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

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

The type returned in the event of a conversion error.

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