Enum BlockKind 

pub enum BlockKind {
    Blpop,
    Brpop,
    Bzpopmin,
    Brpoplpush,
    XReadBlock,
    XReadGroupBlock,
}

Which blocking command a waiter is parked in. Drives both timeout-nil shape and wake-retry dispatch.

Variants

Blpop

Brpop

Bzpopmin

BZPOPMIN key [key ...] timeout — block until a sorted set has a member, then pop the lowest-scored one. Same arm-and-serve flow as BLPOP; the reply shape adds a third bulk (the score).

Brpoplpush

BRPOPLPUSH source destination timeout — atomic blocking right-pop from source + left-push to destination. Parks on source only. Reply: single bulk of the moved element on success, nil bulk on timeout. Deprecated since Redis 6.2 in favour of BLMOVE, but Bee Queue (and many older clients) still emit it.

XReadBlock

XReadGroupBlock

Trait Implementations

impl Clone for BlockKind

fn clone(&self) -> BlockKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BlockKind

impl Debug for BlockKind

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

Formats the value using the given formatter.

impl Eq for BlockKind

impl PartialEq for BlockKind

fn eq(&self, other: &BlockKind) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for BlockKind