@@ -10,7 +10,7 @@ use orchestration::{
1010} ;
1111use serde:: { Deserialize , Serialize } ;
1212use serde_json:: Value ;
13- use std:: sync:: Arc ;
13+ use std:: sync:: { Arc , Mutex } ;
1414
1515async fn generic_just_log_task ( name : & str ) -> InvokeResult {
1616 info ! ( id = name) ;
@@ -52,7 +52,7 @@ impl BasicIfElse {
5252
5353 let branch_true_tag = design. register_invoke_async ( "branch_true" . into ( ) , just_log_task ! ( "true" ) ) ?;
5454 let branch_false_tag = design. register_invoke_async ( "branch_false" . into ( ) , just_log_task ! ( "false" ) ) ?;
55- let condition_tag = design. register_if_else_arc_condition ( "condition" . into ( ) , Arc :: new ( SettableCondition { condition } ) ) ?;
55+ let condition_tag = design. register_if_else_arc_mutex_condition ( "condition" . into ( ) , Arc :: new ( Mutex :: new ( SettableCondition { condition } ) ) ) ?;
5656
5757 design. add_program ( "basic_if_else_program" , move |design, builder| {
5858 builder. with_run_action ( IfElse :: from_tag (
@@ -119,7 +119,7 @@ impl NestedIfElse {
119119 design. register_invoke_async ( "branch_false_true" . into ( ) , just_log_task ! ( "false_true" ) ) ?;
120120 design. register_invoke_async ( "branch_false_false" . into ( ) , just_log_task ! ( "false_false" ) ) ?;
121121 design. register_if_else_arc_condition ( "outer_condition" . into ( ) , Arc :: new ( SettableCondition { condition : outer_condition } ) ) ?;
122- design. register_if_else_arc_condition ( "inner_condition" . into ( ) , Arc :: new ( SettableCondition { condition : inner_condition } ) ) ?;
122+ design. register_if_else_condition ( "inner_condition" . into ( ) , SettableCondition { condition : inner_condition } ) ?;
123123
124124 design. add_program ( "basic_if_else_program" , move |design, builder| {
125125 builder. with_run_action ( IfElse :: from_design (
0 commit comments