Struct SaturatorHandle 

pub struct SaturatorHandle<T> { /* private fields */ }

Handle to send work to a saturator.

The handle is cheap to clone and can be shared across threads. When all handles are dropped, the saturator will finish processing remaining work and shut down.

Implementations

impl<T: Send + 'static> SaturatorHandle<T>

pub fn submit(&self, work: T, scope: Option<&EventScope>)

Submit high-priority work with optional scope tracking.

Follows the EventScope pattern from event_bus.rs:252-259: scope is incremented before submit and decremented after completion.

Arguments

• work - The work data to process
• scope - Optional scope for lifecycle tracking

pub fn submit_background(&self, work: T, scope: Option<&EventScope>)

Submit low-priority background work.

Arguments

• work - The work data to process
• scope - Optional scope for lifecycle tracking

pub fn submit_request(&self, request: SaturationRequest<T>)

Submit a request with explicit priority.

pub fn shutdown(&self)

Request shutdown of the saturator.

The worker will finish processing remaining items before stopping.

pub fn is_shutting_down(&self) -> bool

Check if the saturator is shutting down.

Trait Implementations

impl<T> Clone for SaturatorHandle<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Drop for SaturatorHandle<T>

fn drop(&mut self)

Executes the destructor for this type.