Struct cdc::rate_limiter::State

struct State {
    block_scan_threshold: usize,
    close_sink_threshold: usize,
    is_sink_closed: AtomicBool,
    ref_count: AtomicUsize,
    wait_queue: RwLock<Queue<Arc<Mutex<Option<Waker>>>>>,
    recv_task: AtomicWaker,
    force_flush_flag: AtomicBool,
}

Fields

block_scan_threshold: usize

close_sink_threshold: usize

is_sink_closed: AtomicBool

ref_count: AtomicUsize

wait_queue: RwLock<Queue<Arc<Mutex<Option<Waker>>>>>

recv_task: AtomicWaker

force_flush_flag: AtomicBool

Implementations

impl State

fn yield_drainer(&self, cx: &mut Context<'_>)

Should only be called from the drainer’s task.

fn unyield_drainer(&self)

Should only be called from the drainer’s task.

fn wake_up_drainer(&self)

Should only be called from a sender’s task.

fn wake_up_one_sender(&self)

Wakes up at most one blocked sender. It is no-op if none is blocked. Should only be called from the drainer’s task.

fn wake_up_all_senders(&self)

Wakes up all blocked senders. It is no-op if none is blocked. Should only be called from the drainer’s task.