Struct CacheIoSubmission 

pub struct CacheIoSubmission<Task, Output> {
    pub ticket: CacheIoTicket<Output>,
    pub joined: bool,
    /* private fields */
}

Prepared cache I/O that admits physical work only when explicitly enqueued.

Fields

ticket: CacheIoTicket<Output>

Ticket shared by the operation owner and all exact-key joiners.

joined: bool

Whether this submission joined an already prepared exact operation.

Implementations

impl<Task, Output: Clone> CacheIoSubmission<Task, Output>

pub fn joined_task_mut(&mut self) -> Option<&mut Task>

Returns the unused backend task when this submission joined existing work.

Backends may disarm task-local rollback guards before the unused task is dropped; the task is never physically executed.

pub fn enqueue(self) -> Result<CacheIoSubmissionOutcome, CacheIoWorkerError>

Admits this prepared task, blocking only on finite queue capacity.

Trait Implementations

impl<Task, Output> Drop for CacheIoSubmission<Task, Output>

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.