Struct AtomicFlowHandle 

pub struct AtomicFlowHandle { /* private fields */ }

Shared control handle for one atomic root-to-intercall execution flow.

The root lyquid resolves it to a flow outcome, while blue inter-calls use the same handle to wait for that outcome and report when their local staged work is fully finalized.

Implementations

impl AtomicFlowHandle

pub fn new(id: u64) -> Self

pub fn id(&self) -> u64

pub fn commit(&self)

pub fn abort(&self)

pub fn mark_blue(&self, lyquid: LyquidID)

pub fn blue_done(&self, lyquid: LyquidID)

pub fn fail(&self, lyquid: LyquidID)

pub async fn wait_outcome(&self) -> AtomicFlowOutcome

pub async fn wait_all_done(&self) -> AtomicFlowOutcome

pub fn touched_lyquids(&self) -> Vec<LyquidID>

Trait Implementations

impl Clone for AtomicFlowHandle

fn clone(&self) -> AtomicFlowHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AtomicFlowHandle

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

Formats the value using the given formatter.