Struct CallbackService 

pub struct CallbackService { /* private fields */ }

Bounded, runtime-owned completion callback executor.

Implementations

impl CallbackService

pub fn new( max_concurrent: usize, default_deadline: Duration, executor: Handle, ) -> Self

Create with a maximum number of concurrent callback tasks.

pub fn inflight(&self) -> usize

Number of callbacks currently executing.

pub fn reserved(&self) -> usize

Reserved + inflight callback slots (admission bound).

pub fn try_reserve(&self) -> Option<CallbackReservation>

Reserve one callback slot at admission (fail closed when full).

pub fn schedule_reserved( &self, reservation: CallbackReservation, callback: Box<dyn CompletionCallback>, end: TransactionEnd, deadline: Option<Duration>, )

Schedule a host callback using an admission reservation (D-029).

If the executor rejects the spawn, the reservation permit is dropped and inflight is not left elevated (D-032).

pub fn schedule( &self, callback: Box<dyn CompletionCallback>, end: TransactionEnd, deadline: Option<Duration>, )

Schedule a host callback on an owned task (does not block the caller).

Prefer [schedule_reserved] after admission. This path still acquires a permit before work; if none are available the callback is dropped fail-closed.

pub async fn drain(&self, deadline: Duration)

Wait until no callbacks are inflight, or until deadline elapses. On expiry, abort owned callback tasks and join briefly (D-029).

Trait Implementations

impl Clone for CallbackService

fn clone(&self) -> CallbackService

Returns a duplicate of the value.

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

Performs copy-assignment from source.