Struct BoundedInterlace 

pub struct BoundedInterlace { /* private fields */ }

One bounded interlace. run drives it to its terminal; dropping that future leaves the operation owned, its observations kept, and closeable. close cancels it and settles started work.

Implementations

impl BoundedInterlace

pub fn new( first: impl Into<Participant>, second: impl Into<Participant>, policy: impl IntoPolicy, operation: InterlaceOperationOptions, ) -> Result<Self>

pub async fn run(&mut self) -> BoundedInterlaceOutcome

Drive to the bounded terminal, after required final output and route settlement. A later call returns the same outcome.

pub async fn close(self) -> Result<()>

Cancel the operation, retire its transport and settle started store work through durable position publication. Ok is settled local cancellation, not convergence; a retained operation failure and any found while closing are returned together.