Debugging scope cleanup

Signed-off-by: Michael X. Grey <mxgrey@intrinsic.ai>

Author: mxgrey

src/chain.rs

@@ -744,26 +744,34 @@ mod tests {
             .input
             .chain(builder)
             .map_block(add)
+            .map_block(print_debug(format!("line {}", line!())))
             .then_scope::<_, ()>(ScopeSettings::default(), |scope, builder| {
                 scope
                 .input
                 .chain(builder)
+                .map_block(print_debug(format!("line {}", line!())))
                 .fork_clone_zip((
                     |chain: Chain<f64>| {
                         chain
+                        .map_block(print_debug(format!("line {}", line!())))
                         .map_block(|value|
                             WaitRequest {
                                 duration: Duration::from_secs_f64(value),
                                 value,
                             }
                         )
+                        .map_block(print_debug(format!("line {}", line!())))
                         .map_async(wait)
+                        .map_block(print_debug(format!("line {}", line!())))
                         .connect(scope.terminate);
                     },
                     |chain: Chain<f64>| {
                         chain
+                        .map_block(print_debug(format!("line {}", line!())))
                         .map_block(|a| (a, a))
+                        .map_block(print_debug(format!("line {}", line!())))
                         .map_block(add)
+                        .map_block(print_debug(format!("line {}", line!())))
                         .connect(scope.terminate);
                     }
                 ));
@@ -782,7 +790,7 @@ mod tests {
         context.run_with_conditions(
             &mut promise,
             FlushConditions::new()
-            .with_update_count(5),
+            .with_update_count(100),
         );
 
         dbg!(context.get_unhandled_errors());

src/testing.rs

@@ -251,7 +251,7 @@ pub fn to_uppercase(value: String) -> String {
     value.to_uppercase()
 }
 
-#[derive(Clone, Copy)]
+#[derive(Clone, Copy, Debug)]
 pub struct WaitRequest<Value> {
     pub duration: std::time::Duration,
     pub value: Value
@@ -269,7 +269,7 @@ pub async fn wait<Value>(request: WaitRequest<Value>) -> Value {
 
 /// Use this to add a blocking map to the chain that simply prints a debug
 /// message and then passes the data along.
-pub fn print_debug<T: std::fmt::Debug>(header: String) -> impl FnOnce(T) -> T {
+pub fn print_debug<T: std::fmt::Debug>(header: String) -> impl Fn(T) -> T {
     move |value| {
         println!("{header}: {value:?}");
         value