Enum BackpressurePolicy

pub enum BackpressurePolicy<T>
where
    T: Send + Sync + Clone + 'static,
{
    BlockOnFull,
    DropOldest,
    DropLatest,
    DropLatestIf {
        predicate: Arc<dyn Fn(&ActionOp<T>) -> bool + Send + Sync>,
    },
    DropOldestIf {
        predicate: Arc<dyn Fn(&ActionOp<T>) -> bool + Send + Sync>,
    },
}

the Backpressure policy

Variants

BlockOnFull

Block the sender when the queue is full

DropOldest

Drop the oldest item when the queue is full

DropLatest

Drop the latest item when the queue is full

DropLatestIf

Drop items based on predicate when the queue is full

Fields

predicate: Arc<dyn Fn(&ActionOp<T>) -> bool + Send + Sync>

DropOldestIf

Drop items based on predicate when the queue is full

Fields

predicate: Arc<dyn Fn(&ActionOp<T>) -> bool + Send + Sync>

Trait Implementations

impl<T> Clone for BackpressurePolicy<T>

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

fn clone(&self) -> BackpressurePolicy<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Default for BackpressurePolicy<T>

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

fn default() -> Self

Returns the “default value” for a type.