Struct DrivePolicy 

pub struct DrivePolicy {
    pub stop: StopWhen,
    pub cancel: Option<CancellationToken>,
    pub on_cancel: OnCancel,
    pub deadline: Option<Duration>,
}

Everything that ends a drive, in one value.

Fields

stop: StopWhen

cancel: Option<CancellationToken>

on_cancel: OnCancel

deadline: Option<Duration>

Wall-clock budget for this drive. A select! arm rather than a timeout() wrapper, so a timed-out caller keeps its state and still reaches its own shutdown path instead of dropping the sink mid-flight (#76).

Implementations

impl DrivePolicy

pub const fn until_exit() -> Self

Run until the reducer quits. No cancel token, no deadline.

pub const fn until_settled() -> Self

Run one turn to completion: stop when idle with nothing queued.

pub fn cancel_with( self, token: Option<CancellationToken>, on_cancel: OnCancel, ) -> Self

pub const fn deadline(self, deadline: Option<Duration>) -> Self

Trait Implementations

impl Clone for DrivePolicy

fn clone(&self) -> DrivePolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DrivePolicy

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

Formats the value using the given formatter.