Struct CtxDagChainFork 

pub struct CtxDagChainFork<C, In, ForkOut, Chain, Arms> { /* private fields */ }

Fork builder on the main chain. Accumulates arms as a tuple.

Implementations

impl<Ctx, In, ForkOut, Chain> CtxDagChainFork<Ctx, In, ForkOut, Chain, ()>

pub fn arm<AOut, ACh>( self, f: impl FnOnce(CtxDagArmSeed<Ctx, ForkOut>) -> CtxDagArm<Ctx, ForkOut, AOut, ACh>, ) -> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, AOut, ACh>,)>

Add the first arm to this fork.

impl<Ctx, In, ForkOut, Chain, A0, C0> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, A0, C0>,)>

pub fn arm<AOut, ACh>( self, f: impl FnOnce(CtxDagArmSeed<Ctx, ForkOut>) -> CtxDagArm<Ctx, ForkOut, AOut, ACh>, ) -> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, A0, C0>, CtxDagArm<Ctx, ForkOut, AOut, ACh>)>

Add a second arm to this fork.

impl<Ctx, In, ForkOut, Chain, A0, C0, A1, C1> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, A0, C0>, CtxDagArm<Ctx, ForkOut, A1, C1>)>

pub fn arm<AOut, ACh>( self, f: impl FnOnce(CtxDagArmSeed<Ctx, ForkOut>) -> CtxDagArm<Ctx, ForkOut, AOut, ACh>, ) -> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, A0, C0>, CtxDagArm<Ctx, ForkOut, A1, C1>, CtxDagArm<Ctx, ForkOut, AOut, ACh>)>

Add a third arm to this fork.

impl<Ctx, In, ForkOut, Chain, A0, C0, A1, C1, A2, C2> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, A0, C0>, CtxDagArm<Ctx, ForkOut, A1, C1>, CtxDagArm<Ctx, ForkOut, A2, C2>)>

pub fn arm<AOut, ACh>( self, f: impl FnOnce(CtxDagArmSeed<Ctx, ForkOut>) -> CtxDagArm<Ctx, ForkOut, AOut, ACh>, ) -> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, A0, C0>, CtxDagArm<Ctx, ForkOut, A1, C1>, CtxDagArm<Ctx, ForkOut, A2, C2>, CtxDagArm<Ctx, ForkOut, AOut, ACh>)>

Add a fourth arm to this fork.

impl<Ctx, In, ForkOut: 'static, Chain, A0: 'static, C0, A1: 'static, C1> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, A0, C0>, CtxDagArm<Ctx, ForkOut, A1, C1>)>

pub fn merge<MOut, Params, S>( self, f: S, registry: &Registry, ) -> CtxDagChain<Ctx, In, MOut, CtxMergeNode2<Chain, C0, C1, S::Step, ForkOut, A0, A1, MOut>>

where MOut: 'static, S: IntoCtxMergeStep<Ctx, (&'static A0, &'static A1), MOut, Params>, S::Step: for<'x> CtxMergeStepCall<Ctx, (&'x A0, &'x A1), Out = MOut>,

Merge two arms with a context-aware merge step.

impl<Ctx, In, ForkOut: 'static, Chain, C0, C1> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, (), C0>, CtxDagArm<Ctx, ForkOut, (), C1>)>

pub fn join( self, ) -> CtxDagChain<Ctx, In, (), CtxJoinNode2<Chain, C0, C1, ForkOut>>

Join two sink arms (all producing ()).

impl<Ctx, In, ForkOut: 'static, Chain, A0: 'static, C0, A1: 'static, C1, A2: 'static, C2> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, A0, C0>, CtxDagArm<Ctx, ForkOut, A1, C1>, CtxDagArm<Ctx, ForkOut, A2, C2>)>

pub fn merge<MOut, Params, S>( self, f: S, registry: &Registry, ) -> CtxDagChain<Ctx, In, MOut, CtxMergeNode3<Chain, C0, C1, C2, S::Step, ForkOut, A0, A1, A2, MOut>>

where MOut: 'static, S: IntoCtxMergeStep<Ctx, (&'static A0, &'static A1, &'static A2), MOut, Params>, S::Step: for<'x> CtxMergeStepCall<Ctx, (&'x A0, &'x A1, &'x A2), Out = MOut>,

Merge three arms with a context-aware merge step.

impl<Ctx, In, ForkOut: 'static, Chain, C0, C1, C2> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, (), C0>, CtxDagArm<Ctx, ForkOut, (), C1>, CtxDagArm<Ctx, ForkOut, (), C2>)>

pub fn join( self, ) -> CtxDagChain<Ctx, In, (), CtxJoinNode3<Chain, C0, C1, C2, ForkOut>>

Join three sink arms (all producing ()).

impl<Ctx, In, ForkOut: 'static, Chain, A0: 'static, C0, A1: 'static, C1, A2: 'static, C2, A3: 'static, C3> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, A0, C0>, CtxDagArm<Ctx, ForkOut, A1, C1>, CtxDagArm<Ctx, ForkOut, A2, C2>, CtxDagArm<Ctx, ForkOut, A3, C3>)>

pub fn merge<MOut, Params, S>( self, f: S, registry: &Registry, ) -> CtxDagChain<Ctx, In, MOut, CtxMergeNode4<Chain, C0, C1, C2, C3, S::Step, ForkOut, A0, A1, A2, A3, MOut>>

where MOut: 'static, S: IntoCtxMergeStep<Ctx, (&'static A0, &'static A1, &'static A2, &'static A3), MOut, Params>, S::Step: for<'x> CtxMergeStepCall<Ctx, (&'x A0, &'x A1, &'x A2, &'x A3), Out = MOut>,

Merge four arms with a context-aware merge step.

impl<Ctx, In, ForkOut: 'static, Chain, C0, C1, C2, C3> CtxDagChainFork<Ctx, In, ForkOut, Chain, (CtxDagArm<Ctx, ForkOut, (), C0>, CtxDagArm<Ctx, ForkOut, (), C1>, CtxDagArm<Ctx, ForkOut, (), C2>, CtxDagArm<Ctx, ForkOut, (), C3>)>

pub fn join( self, ) -> CtxDagChain<Ctx, In, (), CtxJoinNode4<Chain, C0, C1, C2, C3, ForkOut>>

Join four sink arms (all producing ()).