Enum BackpressurePolicy 

pub enum BackpressurePolicy<T>
where
    T: Send + Sync + Clone + 'static,
{
    BlockOnFull,
    DropLatestIf(Option<Box<dyn Fn(&T) -> bool + Send + Sync>>),
    DropOldestIf(Option<Box<dyn Fn(&T) -> bool + Send + Sync>>),
}

the Backpressure policy

Variants

BlockOnFull

Block the sender when the queue is full

DropLatestIf(Option<Box<dyn Fn(&T) -> bool + Send + Sync>>)

Drop items based on predicate when the queue is full, it drops from the newest to the oldest With this policy, [send] method can be Err when all items are not droppable Predicate is only applied to ActionOp::Action variants, other variants are never dropped

DropOldestIf(Option<Box<dyn Fn(&T) -> bool + Send + Sync>>)

Drop items based on predicate when the queue is full, it drops from the oldest to the newest With this policy, [send] method can be Err when all items are not droppable Predicate is only applied to ActionOp::Action variants, other variants are never dropped

Trait Implementations

impl<T> Default for BackpressurePolicy<T>

where T: Send + Sync + Clone + 'static,

fn default() -> BackpressurePolicy<T>

Returns the “default value” for a type.