Enum libp2p_mplex::MaxBufferBehaviour [−][src]
Behaviour when the maximum length of the buffer is reached.
Variants
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.
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]
fn clone(&self) -> MaxBufferBehaviour
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for MaxBufferBehaviour
[src]
impl Debug for MaxBufferBehaviour
[src]
impl Eq for MaxBufferBehaviour
[src]
impl PartialEq<MaxBufferBehaviour> for MaxBufferBehaviour
[src]
fn eq(&self, other: &MaxBufferBehaviour) -> bool
[src]
#[must_use]pub fn ne(&self, other: &Rhs) -> bool
1.0.0[src]
impl StructuralEq for MaxBufferBehaviour
[src]
impl StructuralPartialEq for MaxBufferBehaviour
[src]
Auto Trait Implementations
impl RefUnwindSafe for MaxBufferBehaviour
[src]
impl Send for MaxBufferBehaviour
[src]
impl Sync for MaxBufferBehaviour
[src]
impl Unpin for MaxBufferBehaviour
[src]
impl UnwindSafe for MaxBufferBehaviour
[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,