Struct OperationControl 

pub struct OperationControl { /* private fields */ }

Cancellation and progress controls shared by one operation pipeline.

Implementations

impl OperationControl

pub fn new(cancellation: CancellationToken) -> Self

Creates controls around the supplied cancellation token.

pub fn with_observer(self, observer: Arc<dyn ProgressObserver>) -> Self

Installs a synchronous progress observer.

pub fn cancellation(&self) -> &CancellationToken

Returns the shared cancellation token.

pub fn checkpoint( &self, phase: ProgressPhase, completed: u64, total: Option<u64>, ) -> Result<()>

Checks cancellation, then emits a bounded progress event.

Trait Implementations

impl Clone for OperationControl

fn clone(&self) -> OperationControl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for OperationControl

fn default() -> OperationControl

Returns the “default value” for a type.