Struct Interception 

pub struct Interception<M, D>(/* private fields */);

Available on crate feature inspect only.

Share this handle with protocol services and any GUI, TUI, or API controller.

Implementations

impl<M, D> Interception<M, D>

pub fn with_changes(changes: Sender<u64>) -> Interception<M, D>

Share invalidation with a larger controller while retaining typed content APIs.

pub fn subscribe_changes(&self) -> Receiver<u64>

pub fn get(&self, id: u64) -> Option<Arc<M>>

pub fn entries(&self) -> Vec<(u64, Arc<M>)>

pub fn enqueue_with( &self, bytes: usize, limits: QueueLimits, make: impl FnOnce(u64) -> M, ) -> Result<Ticket<M, D>, QueueFull>

Reserve admission and assign an ID atomically. The constructor runs only after admission succeeds, under the queue lock, and must not re-enter it.

pub fn enqueue( &self, message: M, bytes: usize, limits: QueueLimits, ) -> Result<Ticket<M, D>, QueueFull>

pub fn resolve_with<E>( &self, id: u64, decide: impl FnOnce(&M) -> Result<D, E>, ) -> Result<bool, E>

Validate and resolve under the same lock. Exactly one caller can win; failed validation leaves the message pending. The callback cannot re-enter.

pub fn resolve(&self, id: u64, decision: D) -> bool

pub fn release_where(&self, decide: impl FnMut(&M) -> Option<D>)

Release a group of related waits atomically, for example one connection. The callback runs under the queue lock and must not re-enter it.

impl<M, D> Interception<M, D>

where M: Send + Sync + 'static, D: Send + 'static,

pub fn subscribe( &self, ) -> impl Stream<Item = Vec<(u64, Arc<M>)>> + Send + 'static

Initial pending content followed by fresh views; slow consumers coalesce updates.

Trait Implementations

impl<M, D> Clone for Interception<M, D>

fn clone(&self) -> Interception<M, D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M, D> Debug for Interception<M, D>

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

Formats the value using the given formatter.

impl<M, D> Default for Interception<M, D>

fn default() -> Interception<M, D>

Returns the “default value” for a type.