Struct ProgramBuilder 

pub struct ProgramBuilder<R: RoleId, M> { /* private fields */ }

Builder for choreographic programs that enforces structural invariants.

Implementations

impl<R: RoleId, M> ProgramBuilder<R, M>

pub fn new() -> Self

Create a new empty builder.

pub fn try_send(self, to: R, msg: M) -> Result<Self, ProgramError>

Fallible send.

pub fn send(self, to: R, msg: M) -> Self

Add a send effect.

pub fn try_recv<T: 'static>(self, from: R) -> Result<Self, ProgramError>

Fallible recv.

pub fn recv<T: 'static>(self, from: R) -> Self

Add a receive effect.

pub fn try_choose( self, at: R, label: <R as RoleId>::Label, ) -> Result<Self, ProgramError>

Fallible choose.

pub fn choose(self, at: R, label: <R as RoleId>::Label) -> Self

Add a choice effect.

pub fn try_offer(self, from: R) -> Result<Self, ProgramError>

Fallible offer.

pub fn offer(self, from: R) -> Self

Add an offer effect.

pub fn try_with_timeout( self, at: R, dur: Duration, body: Program<R, M>, ) -> Result<Self, ProgramError>

Fallible with_timeout.

pub fn with_timeout(self, at: R, dur: Duration, body: Program<R, M>) -> Self

Add a timeout effect.

pub fn with_timed_choice( self, at: R, dur: Duration, body: Program<R, M>, on_timeout: Program<R, M>, ) -> Self

Add a timed choice effect - races body against timeout.

If body completes before timeout, executes body. If timeout fires first, executes on_timeout instead. This is the effect-level representation of timed_choice syntax.

pub fn try_parallel( self, programs: Vec<Program<R, M>>, ) -> Result<Self, ProgramError>

Add a parallel composition effect.

pub fn parallel(self, programs: Vec<Program<R, M>>) -> Self

Add a parallel composition effect.

pub fn try_branch( self, choosing_role: R, branches: Vec<(<R as RoleId>::Label, Program<R, M>)>, ) -> Result<Self, ProgramError>

Add a branch effect with multiple labeled continuations.

pub fn branch( self, choosing_role: R, branches: Vec<(<R as RoleId>::Label, Program<R, M>)>, ) -> Self

Add a branch effect with multiple labeled continuations.

pub fn try_loop_n( self, iterations: usize, body: Program<R, M>, ) -> Result<Self, ProgramError>

Add a loop effect.

pub fn loop_n(self, iterations: usize, body: Program<R, M>) -> Self

Add a loop effect.

pub fn try_loop_inf(self, body: Program<R, M>) -> Result<Self, ProgramError>

Add an infinite loop effect (or until break).

pub fn loop_inf(self, body: Program<R, M>) -> Self

Add an infinite loop effect (or until break).

pub fn try_ext<E: ExtensionEffect<R> + 'static>( self, extension: E, ) -> Result<Self, ProgramError>

Add a domain-specific extension effect.

pub fn ext<E: ExtensionEffect<R> + 'static>(self, extension: E) -> Self

Add a domain-specific extension effect.

pub fn try_exts<E: ExtensionEffect<R> + 'static>( self, extensions: impl IntoIterator<Item = E>, ) -> Result<Self, ProgramError>

Add multiple extension effects.

pub fn exts<E: ExtensionEffect<R> + 'static>( self, extensions: impl IntoIterator<Item = E>, ) -> Self

Add multiple extension effects.

pub fn end(self) -> Program<R, M>

Mark the end of the program and finalize it.

Prefer ProgramBuilder::try_end for fallible construction.

pub fn try_end(self) -> Result<Program<R, M>, ProgramError>

Fallible variant of ProgramBuilder::end.

pub fn build(self) -> Result<Program<R, M>, ProgramError>

Validate and build the program without appending End.

Trait Implementations

impl<R: Clone + RoleId, M: Clone> Clone for ProgramBuilder<R, M>

fn clone(&self) -> ProgramBuilder<R, M>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<R: Debug + RoleId, M: Debug> Debug for ProgramBuilder<R, M>

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

Formats the value using the given formatter.

impl<R: RoleId, M> Default for ProgramBuilder<R, M>

fn default() -> Self

Returns the “default value” for a type.