Struct ScanOnceQueue 

pub struct ScanOnceQueue { /* private fields */ }

The scanOnce facility: one bounded ring drained by one worker thread.

Dropping it stops and joins the worker.

Implementations

impl ScanOnceQueue

pub fn new() -> Self

Build with the C default capacity (onceQueueSize, dbScan.c:65).

pub fn with_capacity(capacity: usize) -> Self

Build with an explicit ring capacity (clamped to at least 1).

pub fn handle(&self) -> ScanOnceHandle

A cheap, clonable submission handle (see ScanOnceHandle).

pub fn scan_once(&self, cb: OnceCallback) -> Result<(), ScanOnceOverflow>

Enqueue cb for one-shot processing — convenience wrapper over ScanOnceHandle::scan_once.

pub fn overflow_count(&self) -> u64

Lifetime overflow count — C onceQOverruns (dbScan.c:68).

Trait Implementations

impl Default for ScanOnceQueue

fn default() -> Self

Returns the “default value” for a type.

impl Drop for ScanOnceQueue

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.