pub struct RejectedAsyncWriter { /* private fields */ }Expand description
Isolated cleanup ownership after a provider returned an invalid identity.
This handle cannot write or publish. Cleanup acts only on resources owned by its session, never on a diagnostic path. Drop performs no explicit cleanup or cancellation hook; retain this handle until cleanup is confirmed.
use qubit_fs::write::RejectedAsyncWriter;
fn cannot_publish(mut recovery: RejectedAsyncWriter) {
recovery.commit();
}§Examples
use qubit_fs::error::RecoveryCleanupState;
use qubit_fs::write::RejectedAsyncWriter;
assert!(std::any::type_name::<RejectedAsyncWriter>().contains("RejectedAsyncWriter"));
assert_eq!(RecoveryCleanupState::Pending, RecoveryCleanupState::Pending);Implementations§
Source§impl RejectedAsyncWriter
impl RejectedAsyncWriter
Sourcepub const fn cleanup_state(&self) -> RecoveryCleanupState
pub const fn cleanup_state(&self) -> RecoveryCleanupState
Returns cleanup progress; errors and cancellation do not release ownership.
Sourcepub fn abort_async(&mut self) -> SpiFuture<'_, FsResult<WriteAbortOutcome>>
pub fn abort_async(&mut self) -> SpiFuture<'_, FsResult<WriteAbortOutcome>>
Explicitly cleans resources actually owned by this isolated session.
A failed attempt retains the session for explicit retry or reconciliation. No work occurs until polled. Dropping a polled, unfinished future records Indeterminate; dropping an unpolled future leaves the state unchanged.
§Errors
Returns InvalidState after confirmed cleanup, or the contextual provider error without replacing the original opening failure.