qubit-function 0.8.1

/*******************************************************************************
 *
 *    Copyright (c) 2025 - 2026.
 *    Haixing Hu, Qubit Co. Ltd.
 *
 *    All rights reserved.
 *
 ******************************************************************************/

//! Tests for Consumer types

use qubit_function::{
    ArcConsumer,
    BoxConsumer,
    Consumer,
    FnConsumerOps,
    RcConsumer,
};
use std::rc::Rc;
use std::sync::Arc;

#[cfg(test)]
mod box_readonly_consumer_tests {
    use super::*;

    #[test]
    fn test_new_and_accept() {
        let consumer = BoxConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        consumer.accept(&5);
    }

    #[test]
    fn test_and_then() {
        let counter = Arc::new(std::sync::Mutex::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();
        let chained = BoxConsumer::new(move |_x: &i32| {
            *c1.lock().unwrap() += 1;
        })
        .and_then(move |_x: &i32| {
            *c2.lock().unwrap() += 1;
        });

        chained.accept(&5);
        assert_eq!(*counter.lock().unwrap(), 2);
    }

    #[test]
    fn test_and_then_with_box_consumer() {
        let counter = Arc::new(std::sync::Mutex::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();

        let first = BoxConsumer::new(move |_x: &i32| {
            *c1.lock().unwrap() += 1;
        });

        let second = BoxConsumer::new(move |_x: &i32| {
            *c2.lock().unwrap() += 1;
        });

        let chained = first.and_then(second);
        chained.accept(&5);
        assert_eq!(*counter.lock().unwrap(), 2);
    }

    #[test]
    fn test_and_then_multiple_chains() {
        let counter = Arc::new(std::sync::Mutex::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();
        let c3 = counter.clone();

        let chained = BoxConsumer::new(move |_x: &i32| {
            *c1.lock().unwrap() += 1;
        })
        .and_then(move |_x: &i32| {
            *c2.lock().unwrap() += 1;
        })
        .and_then(move |_x: &i32| {
            *c3.lock().unwrap() += 1;
        });

        chained.accept(&5);
        assert_eq!(*counter.lock().unwrap(), 3);
    }

    #[test]
    fn test_noop() {
        let noop = BoxConsumer::<i32>::noop();
        noop.accept(&42);
        // Should not panic
    }

    #[test]
    fn test_arc_noop() {
        let noop = ArcConsumer::<i32>::noop();
        noop.accept(&42);
        // Should not panic
    }

    #[test]
    fn test_into_box() {
        let closure = |x: &i32| {
            println!("Value: {}", x);
        };
        let box_consumer = closure.into_box();
        box_consumer.accept(&5);
    }

    #[test]
    fn test_into_rc() {
        let consumer = BoxConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let rc_consumer = consumer.into_rc();
        rc_consumer.accept(&5);
    }

    #[test]
    fn test_into_fn() {
        let consumer = BoxConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let func = consumer.into_fn();
        func(&5);
    }

    #[test]
    fn test_box_consumer_into_box() {
        // Test BoxConsumer's own into_box() method
        let consumer = BoxConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let box_consumer = consumer.into_box();
        box_consumer.accept(&5);
    }

    #[test]
    fn test_name() {
        let mut consumer = BoxConsumer::<i32>::noop();
        assert_eq!(consumer.name(), None);

        consumer.set_name("test_consumer");
        assert_eq!(consumer.name(), Some("test_consumer"));
    }

    #[test]
    fn test_debug() {
        let consumer = BoxConsumer::<i32>::noop();
        let debug_str = format!("{:?}", consumer);
        assert!(debug_str.contains("BoxConsumer"));
    }

    #[test]
    fn test_display() {
        let mut consumer = BoxConsumer::<i32>::noop();
        assert_eq!(format!("{}", consumer), "BoxConsumer");

        consumer.set_name("my_consumer");
        assert_eq!(format!("{}", consumer), "BoxConsumer(my_consumer)");
    }

    #[test]
    fn test_with_different_types() {
        let string_consumer = BoxConsumer::new(|s: &String| {
            println!("String: {}", s);
        });
        string_consumer.accept(&"Hello".to_string());

        let vec_consumer = BoxConsumer::new(|v: &Vec<i32>| {
            println!("Vec length: {}", v.len());
        });
        vec_consumer.accept(&vec![1, 2, 3]);
    }
}

#[cfg(test)]
mod arc_readonly_consumer_tests {
    use super::*;

    #[test]
    fn test_new_and_accept() {
        let consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        consumer.accept(&5);
    }

    #[test]
    fn test_clone() {
        let counter = Arc::new(std::sync::atomic::AtomicUsize::new(0));
        let c = counter.clone();
        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, std::sync::atomic::Ordering::SeqCst);
        });

        let clone = consumer.clone();
        consumer.accept(&5);
        clone.accept(&10);

        assert_eq!(counter.load(std::sync::atomic::Ordering::SeqCst), 2);
    }

    #[test]
    fn test_and_then() {
        let counter = Arc::new(std::sync::atomic::AtomicUsize::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();

        let first = ArcConsumer::new(move |_x: &i32| {
            c1.fetch_add(1, std::sync::atomic::Ordering::SeqCst);
        });

        let second = ArcConsumer::new(move |_x: &i32| {
            c2.fetch_add(1, std::sync::atomic::Ordering::SeqCst);
        });

        let chained = first.and_then(second.clone());
        chained.accept(&5);

        assert_eq!(counter.load(std::sync::atomic::Ordering::SeqCst), 2);

        // Original consumers remain usable
        first.accept(&10);
        second.accept(&15);
        assert_eq!(counter.load(std::sync::atomic::Ordering::SeqCst), 4);
    }

    #[test]
    fn test_into_box() {
        let consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let box_consumer = consumer.into_box();
        box_consumer.accept(&5);
    }

    #[test]
    fn test_into_rc() {
        let consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let rc_consumer = consumer.into_rc();
        rc_consumer.accept(&5);
    }

    #[test]
    fn test_into_arc() {
        let consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let arc_consumer = consumer.into_arc();
        arc_consumer.accept(&5);
    }

    #[test]
    fn test_into_fn() {
        let consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let func = consumer.into_fn();
        func(&5);
    }

    #[test]
    fn test_to_fn() {
        let consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let func = consumer.to_fn();
        func(&5);

        // Original consumer remains usable
        consumer.accept(&10);
    }

    #[test]
    fn test_name() {
        let mut consumer = ArcConsumer::new(|_x: &i32| {});
        assert_eq!(consumer.name(), None);

        consumer.set_name("test_consumer");
        assert_eq!(consumer.name(), Some("test_consumer"));
    }

    #[test]
    fn test_debug() {
        let consumer = ArcConsumer::new(|_x: &i32| {});
        let debug_str = format!("{:?}", consumer);
        assert!(debug_str.contains("ArcConsumer"));
    }

    #[test]
    fn test_display() {
        let mut consumer = ArcConsumer::new(|_x: &i32| {});
        assert_eq!(format!("{}", consumer), "ArcConsumer");

        consumer.set_name("my_consumer");
        assert_eq!(format!("{}", consumer), "ArcConsumer(my_consumer)");
    }

    #[test]
    fn test_thread_safety() {
        let counter = Arc::new(std::sync::atomic::AtomicUsize::new(0));
        let c = counter.clone();
        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, std::sync::atomic::Ordering::SeqCst);
        });

        let handles: Vec<_> = (0..10)
            .map(|i| {
                let consumer_clone = consumer.clone();
                std::thread::spawn(move || {
                    consumer_clone.accept(&i);
                })
            })
            .collect();

        for handle in handles {
            handle.join().unwrap();
        }

        assert_eq!(counter.load(std::sync::atomic::Ordering::SeqCst), 10);
    }
}

#[cfg(test)]
mod rc_readonly_consumer_tests {
    use super::*;

    #[test]
    fn test_new_and_accept() {
        let consumer = RcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        consumer.accept(&5);
    }

    #[test]
    fn test_rc_noop() {
        let noop = RcConsumer::<i32>::noop();
        noop.accept(&42);
        // Should not panic
    }

    #[test]
    fn test_clone() {
        let counter = Rc::new(std::cell::RefCell::new(0));
        let c = counter.clone();
        let consumer = RcConsumer::new(move |_x: &i32| {
            *c.borrow_mut() += 1;
        });

        let clone = consumer.clone();
        consumer.accept(&5);
        clone.accept(&10);

        assert_eq!(*counter.borrow(), 2);
    }

    #[test]
    fn test_and_then() {
        let counter = Rc::new(std::cell::RefCell::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();

        let first = RcConsumer::new(move |_x: &i32| {
            *c1.borrow_mut() += 1;
        });

        let second = RcConsumer::new(move |_x: &i32| {
            *c2.borrow_mut() += 1;
        });

        let chained = first.and_then(second.clone());
        chained.accept(&5);

        assert_eq!(*counter.borrow(), 2);

        // Original consumers remain usable
        first.accept(&10);
        second.accept(&15);
        assert_eq!(*counter.borrow(), 4);
    }

    #[test]
    fn test_into_box() {
        let consumer = RcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let box_consumer = consumer.into_box();
        box_consumer.accept(&5);
    }

    #[test]
    fn test_into_rc() {
        let consumer = RcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let rc_consumer = consumer.into_rc();
        rc_consumer.accept(&5);
    }

    #[test]
    fn test_into_fn() {
        let consumer = RcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let func = consumer.into_fn();
        func(&5);
    }

    #[test]
    fn test_to_fn() {
        let consumer = RcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let func = consumer.to_fn();
        func(&5);

        // Original consumer remains usable
        consumer.accept(&10);
    }

    #[test]
    fn test_name() {
        let mut consumer = RcConsumer::new(|_x: &i32| {});
        assert_eq!(consumer.name(), None);

        consumer.set_name("test_consumer");
        assert_eq!(consumer.name(), Some("test_consumer"));
    }

    #[test]
    fn test_debug() {
        let consumer = RcConsumer::new(|_x: &i32| {});
        let debug_str = format!("{:?}", consumer);
        assert!(debug_str.contains("RcConsumer"));
    }

    #[test]
    fn test_display() {
        let mut consumer = RcConsumer::new(|_x: &i32| {});
        assert_eq!(format!("{}", consumer), "RcConsumer");

        consumer.set_name("my_consumer");
        assert_eq!(format!("{}", consumer), "RcConsumer(my_consumer)");
    }
}

#[cfg(test)]
mod closure_tests {
    use super::*;

    #[test]
    fn test_closure_accept() {
        let closure = |x: &i32| {
            println!("Value: {}", x);
        };
        closure.accept(&5);
    }

    #[test]
    fn test_closure_into_box() {
        let closure = |x: &i32| {
            println!("Value: {}", x);
        };
        let box_consumer = closure.into_box();
        box_consumer.accept(&5);
    }

    #[test]
    fn test_closure_into_rc() {
        let closure = |x: &i32| {
            println!("Value: {}", x);
        };
        let rc_consumer = closure.into_rc();
        rc_consumer.accept(&5);
    }

    #[test]
    fn test_closure_into_arc() {
        let closure = |x: &i32| {
            println!("Value: {}", x);
        };
        let arc_consumer = closure.into_arc();
        arc_consumer.accept(&5);
    }

    #[test]
    fn test_closure_into_fn() {
        let closure = |x: &i32| {
            println!("Value: {}", x);
        };
        let func = closure.into_fn();
        func(&5);
    }

    #[test]
    fn test_closure_and_then() {
        let counter = Arc::new(std::sync::Mutex::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();

        let chained = (move |_x: &i32| {
            *c1.lock().unwrap() += 1;
        })
        .and_then(move |_x: &i32| {
            *c2.lock().unwrap() += 1;
        });

        chained.accept(&5);
        assert_eq!(*counter.lock().unwrap(), 2);
    }

    #[test]
    fn test_closure_and_then_multiple() {
        let counter = Arc::new(std::sync::Mutex::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();
        let c3 = counter.clone();

        let chained = (move |_x: &i32| {
            *c1.lock().unwrap() += 1;
        })
        .and_then(move |_x: &i32| {
            *c2.lock().unwrap() += 1;
        })
        .and_then(move |_x: &i32| {
            *c3.lock().unwrap() += 1;
        });

        chained.accept(&5);
        assert_eq!(*counter.lock().unwrap(), 3);
    }
}

#[cfg(test)]
mod conversion_tests {
    use super::*;

    #[test]
    fn test_box_to_rc() {
        let box_consumer = BoxConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let rc_consumer = box_consumer.into_rc();
        rc_consumer.accept(&5);
    }

    #[test]
    fn test_arc_to_box() {
        let arc_consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let box_consumer = arc_consumer.into_box();
        box_consumer.accept(&5);
    }

    #[test]
    fn test_arc_to_rc() {
        let arc_consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let rc_consumer = arc_consumer.into_rc();
        rc_consumer.accept(&5);
    }

    #[test]
    fn test_rc_to_box() {
        let rc_consumer = RcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        let box_consumer = rc_consumer.into_box();
        box_consumer.accept(&5);
    }

    // Note: Box and Rc cannot be converted to Arc because they don't implement Send+Sync
    // These conversions are prevented at compile time, not runtime
}

#[cfg(test)]
mod generic_tests {
    use super::*;

    fn apply_consumer<C: Consumer<i32>>(consumer: &C, value: &i32) {
        consumer.accept(value);
    }

    #[test]
    fn test_with_box_consumer() {
        let box_consumer = BoxConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        apply_consumer(&box_consumer, &5);
    }

    #[test]
    fn test_with_arc_consumer() {
        let arc_consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        apply_consumer(&arc_consumer, &5);
    }

    #[test]
    fn test_with_rc_consumer() {
        let rc_consumer = RcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        apply_consumer(&rc_consumer, &5);
    }

    #[test]
    fn test_with_closure() {
        let closure = |x: &i32| {
            println!("Value: {}", x);
        };
        apply_consumer(&closure, &5);
    }
}

// ============================================================================
// Name Tests - Testing name() and set_name() methods
// ============================================================================

#[cfg(test)]
mod name_tests {
    use super::*;

    #[test]
    fn test_box_consumer_name() {
        let mut consumer = BoxConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        assert_eq!(consumer.name(), None);

        consumer.set_name("printer");
        assert_eq!(consumer.name(), Some("printer"));
    }

    #[test]
    fn test_arc_consumer_name() {
        let mut consumer = ArcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        assert_eq!(consumer.name(), None);

        consumer.set_name("printer");
        assert_eq!(consumer.name(), Some("printer"));
    }

    #[test]
    fn test_rc_consumer_name() {
        let mut consumer = RcConsumer::new(|x: &i32| {
            println!("Value: {}", x);
        });
        assert_eq!(consumer.name(), None);

        consumer.set_name("printer");
        assert_eq!(consumer.name(), Some("printer"));
    }

    #[test]
    fn test_box_consumer_name_with_accept() {
        let mut consumer = BoxConsumer::new(|_x: &i32| {});
        consumer.set_name("test_consumer");
        assert_eq!(consumer.name(), Some("test_consumer"));
        consumer.accept(&1);
        assert_eq!(consumer.name(), Some("test_consumer"));
    }

    #[test]
    fn test_arc_consumer_name_with_accept() {
        let mut consumer = ArcConsumer::new(|_x: &i32| {});
        consumer.set_name("test_consumer");
        assert_eq!(consumer.name(), Some("test_consumer"));
        consumer.accept(&1);
        assert_eq!(consumer.name(), Some("test_consumer"));
    }

    #[test]
    fn test_rc_consumer_name_with_accept() {
        let mut consumer = RcConsumer::new(|_x: &i32| {});
        consumer.set_name("test_consumer");
        assert_eq!(consumer.name(), Some("test_consumer"));
        consumer.accept(&1);
        assert_eq!(consumer.name(), Some("test_consumer"));
    }

    #[test]
    fn test_box_consumer_into_rc_preserves_name() {
        let mut consumer = BoxConsumer::new(|_x: &i32| {});
        consumer.set_name("original_consumer");
        assert_eq!(consumer.name(), Some("original_consumer"));

        let converted = consumer.into_rc();
        assert_eq!(converted.name(), Some("original_consumer"));
    }

    #[test]
    fn test_rc_consumer_into_box_preserves_name() {
        let mut consumer = RcConsumer::new(|_x: &i32| {});
        consumer.set_name("original_consumer");
        assert_eq!(consumer.name(), Some("original_consumer"));

        let converted = consumer.into_box();
        assert_eq!(converted.name(), Some("original_consumer"));
    }

    #[test]
    fn test_arc_consumer_into_box_preserves_name() {
        let mut consumer = ArcConsumer::new(|_x: &i32| {});
        consumer.set_name("original_consumer");
        assert_eq!(consumer.name(), Some("original_consumer"));

        let converted = consumer.into_box();
        assert_eq!(converted.name(), Some("original_consumer"));
    }

    #[test]
    fn test_arc_consumer_into_rc_preserves_name() {
        let mut consumer = ArcConsumer::new(|_x: &i32| {});
        consumer.set_name("original_consumer");
        assert_eq!(consumer.name(), Some("original_consumer"));

        let converted = consumer.into_rc();
        assert_eq!(converted.name(), Some("original_consumer"));
    }

    #[test]
    fn test_rc_consumer_to_box_preserves_name() {
        let mut consumer = RcConsumer::new(|_x: &i32| {});
        consumer.set_name("original_consumer");
        assert_eq!(consumer.name(), Some("original_consumer"));

        let converted = consumer.to_box();
        assert_eq!(converted.name(), Some("original_consumer"));
    }

    #[test]
    fn test_arc_consumer_to_box_preserves_name() {
        let mut consumer = ArcConsumer::new(|_x: &i32| {});
        consumer.set_name("original_consumer");
        assert_eq!(consumer.name(), Some("original_consumer"));

        let converted = consumer.to_box();
        assert_eq!(converted.name(), Some("original_consumer"));
    }

    #[test]
    fn test_arc_consumer_to_rc_preserves_name() {
        let mut consumer = ArcConsumer::new(|_x: &i32| {});
        consumer.set_name("original_consumer");
        assert_eq!(consumer.name(), Some("original_consumer"));

        let converted = consumer.to_rc();
        assert_eq!(converted.name(), Some("original_consumer"));
    }
}

// ============================================================================
// Display and Debug Tests
// ============================================================================

#[cfg(test)]
mod display_debug_tests {
    use super::*;

    #[test]
    fn test_box_consumer_debug() {
        let consumer = BoxConsumer::new(|_x: &i32| {});
        let debug_str = format!("{:?}", consumer);
        assert!(debug_str.contains("BoxConsumer"));
        assert!(debug_str.contains("name"));
        assert!(debug_str.contains("function"));
    }

    #[test]
    fn test_box_consumer_display_without_name() {
        let consumer = BoxConsumer::new(|_x: &i32| {});
        let display_str = format!("{}", consumer);
        assert_eq!(display_str, "BoxConsumer");
    }

    #[test]
    fn test_box_consumer_display_with_name() {
        let mut consumer = BoxConsumer::new(|_x: &i32| {});
        consumer.set_name("test_consumer");
        let display_str = format!("{}", consumer);
        assert_eq!(display_str, "BoxConsumer(test_consumer)");
    }

    #[test]
    fn test_arc_consumer_debug() {
        let consumer = ArcConsumer::new(|_x: &i32| {});
        let debug_str = format!("{:?}", consumer);
        assert!(debug_str.contains("ArcConsumer"));
        assert!(debug_str.contains("name"));
        assert!(debug_str.contains("function"));
    }

    #[test]
    fn test_arc_consumer_display_without_name() {
        let consumer = ArcConsumer::new(|_x: &i32| {});
        let display_str = format!("{}", consumer);
        assert_eq!(display_str, "ArcConsumer");
    }

    #[test]
    fn test_arc_consumer_display_with_name() {
        let mut consumer = ArcConsumer::new(|_x: &i32| {});
        consumer.set_name("test_consumer");
        let display_str = format!("{}", consumer);
        assert_eq!(display_str, "ArcConsumer(test_consumer)");
    }

    #[test]
    fn test_rc_consumer_debug() {
        let consumer = RcConsumer::new(|_x: &i32| {});
        let debug_str = format!("{:?}", consumer);
        assert!(debug_str.contains("RcConsumer"));
        assert!(debug_str.contains("name"));
        assert!(debug_str.contains("function"));
    }

    #[test]
    fn test_rc_consumer_display_without_name() {
        let consumer = RcConsumer::new(|_x: &i32| {});
        let display_str = format!("{}", consumer);
        assert_eq!(display_str, "RcConsumer");
    }

    #[test]
    fn test_rc_consumer_display_with_name() {
        let mut consumer = RcConsumer::new(|_x: &i32| {});
        consumer.set_name("test_consumer");
        let display_str = format!("{}", consumer);
        assert_eq!(display_str, "RcConsumer(test_consumer)");
    }
}

#[cfg(test)]
mod custom_struct_tests {
    use super::*;
    use std::sync::atomic::{
        AtomicUsize,
        Ordering,
    };
    use std::sync::Arc;

    pub struct MyConsumer {
        counter: Arc<AtomicUsize>,
    }

    impl MyConsumer {
        pub fn new(counter: Arc<AtomicUsize>) -> Self {
            Self { counter }
        }
    }

    impl Consumer<i32> for MyConsumer {
        fn accept(&self, _value: &i32) {
            self.counter.fetch_add(1, Ordering::SeqCst);
        }
    }

    #[test]
    fn test_into_variants_from_custom_struct() {
        let counter = Arc::new(AtomicUsize::new(0));

        // into_box()
        let my = MyConsumer::new(counter.clone());
        let box_cons = my.into_box();
        box_cons.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // into_rc()
        let my2 = MyConsumer::new(counter.clone());
        let rc_cons = my2.into_rc();
        rc_cons.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 2);

        // into_arc()
        let my3 = MyConsumer::new(counter.clone());
        let arc_cons = my3.into_arc();
        arc_cons.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 3);

        // into_fn()
        let my4 = MyConsumer::new(counter.clone());
        let func = my4.into_fn();
        func(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 4);
    }

    impl Clone for MyConsumer {
        fn clone(&self) -> Self {
            Self {
                counter: self.counter.clone(),
            }
        }
    }

    #[test]
    fn test_to_variants_from_custom_struct() {
        let counter = Arc::new(AtomicUsize::new(0));

        let my = MyConsumer::new(counter.clone());

        // to_box() - Does not consume the original object
        let box_cons = my.to_box();
        box_cons.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // to_rc() - Does not consume the original object
        let rc_cons = my.to_rc();
        rc_cons.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 2);

        // to_arc() - Does not consume the original object
        let arc_cons = my.to_arc();
        arc_cons.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 3);

        // to_fn() - Does not consume the original object
        let func = my.to_fn();
        func(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 4);

        // Original object remains usable
        my.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 5);
    }
}

// ============================================================================
// to_xxx Methods Tests - Testing non-consuming conversion methods
// ============================================================================

#[cfg(test)]
mod to_xxx_methods_tests {
    use super::*;
    use std::sync::atomic::{
        AtomicUsize,
        Ordering,
    };

    // BoxConsumer cannot implement Clone because it uses Box<dyn Fn>
    // So it cannot have to_box, to_rc, to_fn methods
    // It can only have into_xxx methods

    #[test]
    fn test_arc_to_box() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();
        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        // to_box() does not consume the original object
        let box_consumer = consumer.to_box();
        box_consumer.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original object remains usable
        consumer.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_arc_to_rc() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();
        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        // to_rc() does not consume the original object
        let rc_consumer = consumer.to_rc();
        rc_consumer.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original object remains usable
        consumer.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_arc_to_arc() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();
        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        // to_arc() does not consume the original object
        let arc_consumer = consumer.to_arc();
        arc_consumer.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original object remains usable
        consumer.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_arc_to_fn() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();
        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        // to_fn() does not consume the original object
        let func = consumer.to_fn();
        func(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original object remains usable
        consumer.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_rc_to_box() {
        let counter = Rc::new(std::cell::RefCell::new(0));
        let c = counter.clone();
        let consumer = RcConsumer::new(move |_x: &i32| {
            *c.borrow_mut() += 1;
        });

        // to_box() does not consume the original object
        let box_consumer = consumer.to_box();
        box_consumer.accept(&1);
        assert_eq!(*counter.borrow(), 1);

        // Original object remains usable
        consumer.accept(&2);
        assert_eq!(*counter.borrow(), 2);
    }

    #[test]
    fn test_rc_to_rc() {
        let counter = Rc::new(std::cell::RefCell::new(0));
        let c = counter.clone();
        let consumer = RcConsumer::new(move |_x: &i32| {
            *c.borrow_mut() += 1;
        });

        // to_rc() does not consume the original object
        let rc_consumer = consumer.to_rc();
        rc_consumer.accept(&1);
        assert_eq!(*counter.borrow(), 1);

        // Original object remains usable
        consumer.accept(&2);
        assert_eq!(*counter.borrow(), 2);
    }

    #[test]
    fn test_rc_to_fn() {
        let counter = Rc::new(std::cell::RefCell::new(0));
        let c = counter.clone();
        let consumer = RcConsumer::new(move |_x: &i32| {
            *c.borrow_mut() += 1;
        });

        // to_fn() does not consume the original object
        let func = consumer.to_fn();
        func(&1);
        assert_eq!(*counter.borrow(), 1);

        // Original object remains usable
        consumer.accept(&2);
        assert_eq!(*counter.borrow(), 2);
    }

    #[test]
    fn test_closure_to_box() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();

        let closure = move |_x: &i32| {
            c1.fetch_add(1, Ordering::SeqCst);
        };

        // to_box() does not consume the original closure
        let box_consumer = closure.to_box();
        box_consumer.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original closure remains usable
        closure.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);

        // Verify that the consumer created by to_box uses an independent closure copy
        let another_closure = move |_x: &i32| {
            c2.fetch_add(1, Ordering::SeqCst);
        };
        let box_consumer2 = another_closure.to_box();
        box_consumer2.accept(&3);
        assert_eq!(counter.load(Ordering::SeqCst), 3);

        another_closure.accept(&4);
        assert_eq!(counter.load(Ordering::SeqCst), 4);
    }

    #[test]
    fn test_closure_to_rc() {
        let counter = Rc::new(std::cell::RefCell::new(0));
        let c = counter.clone();

        let closure = move |_x: &i32| {
            *c.borrow_mut() += 1;
        };

        // to_rc() does not consume the original closure
        let rc_consumer = closure.to_rc();
        rc_consumer.accept(&1);
        assert_eq!(*counter.borrow(), 1);

        // Original closure remains usable
        closure.accept(&2);
        assert_eq!(*counter.borrow(), 2);
    }

    #[test]
    fn test_closure_to_arc() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let closure = move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        };

        // to_arc() does not consume the original closure
        let arc_consumer = closure.to_arc();
        arc_consumer.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original closure remains usable
        closure.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_closure_to_fn() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let closure = move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        };

        // to_fn() does not consume the original closure
        let func = closure.to_fn();
        func(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original closure remains usable
        closure.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_arc_to_xxx_all_methods() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();
        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        // Call all to_xxx methods in sequence to verify the original object is not consumed
        let box_consumer = consumer.to_box();
        box_consumer.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        let rc_consumer = consumer.to_rc();
        rc_consumer.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);

        let arc_consumer = consumer.to_arc();
        arc_consumer.accept(&3);
        assert_eq!(counter.load(Ordering::SeqCst), 3);

        let func = consumer.to_fn();
        func(&4);
        assert_eq!(counter.load(Ordering::SeqCst), 4);

        // Finally verify the original object remains usable
        consumer.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 5);
    }

    #[test]
    fn test_rc_to_xxx_all_methods() {
        let counter = Rc::new(std::cell::RefCell::new(0));
        let c = counter.clone();
        let consumer = RcConsumer::new(move |_x: &i32| {
            *c.borrow_mut() += 1;
        });

        // Call all to_xxx methods in sequence to verify the original object is not consumed
        let box_consumer = consumer.to_box();
        box_consumer.accept(&1);
        assert_eq!(*counter.borrow(), 1);

        let rc_consumer = consumer.to_rc();
        rc_consumer.accept(&2);
        assert_eq!(*counter.borrow(), 2);

        let func = consumer.to_fn();
        func(&3);
        assert_eq!(*counter.borrow(), 3);

        // Finally verify the original object remains usable
        consumer.accept(&4);
        assert_eq!(*counter.borrow(), 4);
    }

    #[test]
    fn test_closure_to_xxx_all_methods() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let closure = move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        };

        // Call all to_xxx methods in sequence to verify the original closure is not consumed
        let box_consumer = closure.to_box();
        box_consumer.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        let rc_consumer = closure.to_rc();
        rc_consumer.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);

        let arc_consumer = closure.to_arc();
        arc_consumer.accept(&3);
        assert_eq!(counter.load(Ordering::SeqCst), 3);

        let func = closure.to_fn();
        func(&4);
        assert_eq!(counter.load(Ordering::SeqCst), 4);

        // Finally verify the original closure remains usable
        closure.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 5);
    }
}

// ============================================================================
// to_once Tests - Testing Consumer trait default to_once implementation
// ============================================================================

#[cfg(test)]
mod to_once_tests {
    use super::*;
    use qubit_function::ConsumerOnce;
    use std::sync::atomic::{
        AtomicUsize,
        Ordering,
    };

    #[test]
    fn test_custom_consumer_to_once() {
        let counter = Arc::new(AtomicUsize::new(0));
        let my_consumer = super::custom_struct_tests::MyConsumer::new(counter.clone());

        // Test to_once() - should not consume the original
        let once_consumer = my_consumer.to_once();
        once_consumer.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original consumer should still be usable
        my_consumer.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_custom_consumer_into_once() {
        let counter = Arc::new(AtomicUsize::new(0));
        let my_consumer = super::custom_struct_tests::MyConsumer::new(counter.clone());

        // Test into_once() - should consume the original
        let once_consumer = my_consumer.into_once();
        once_consumer.accept(&1);
        assert_eq!(counter.load(Ordering::SeqCst), 1);
    }

    #[test]
    fn test_closure_into_once() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let closure = move |x: &i32| {
            c.fetch_add(*x as usize, Ordering::SeqCst);
        };

        // Test into_once() - should consume the closure
        let once_consumer = closure.into_once();
        once_consumer.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 5);
    }

    #[test]
    fn test_closure_to_once() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let closure = move |x: &i32| {
            c.fetch_add(*x as usize, Ordering::SeqCst);
        };

        // Test to_once() - should not consume the original closure
        let once_consumer = closure.to_once();
        once_consumer.accept(&3);
        assert_eq!(counter.load(Ordering::SeqCst), 3);

        // Original closure should still be usable
        closure.accept(&2);
        assert_eq!(counter.load(Ordering::SeqCst), 5);
    }
}

// ============================================================================
// Conditional Consumer Tests
// ============================================================================

#[cfg(test)]
mod box_conditional_consumer_tests {
    use super::*;
    use std::sync::Mutex;

    #[test]
    fn test_box_conditional_and_then() {
        let log = Arc::new(Mutex::new(Vec::new()));
        let l1 = log.clone();
        let l2 = log.clone();

        let consumer = BoxConsumer::new(move |x: &i32| {
            l1.lock().unwrap().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let chained = conditional.and_then(move |x: &i32| {
            l2.lock().unwrap().push(*x * 2);
        });

        chained.accept(&5);
        assert_eq!(*log.lock().unwrap(), vec![5, 10]);

        chained.accept(&-5);
        assert_eq!(*log.lock().unwrap(), vec![5, 10, -10]);
    }

    #[test]
    fn test_box_conditional_or_else() {
        let log = Arc::new(Mutex::new(Vec::new()));
        let l1 = log.clone();
        let l2 = log.clone();

        let consumer = BoxConsumer::new(move |x: &i32| {
            l1.lock().unwrap().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0).or_else(move |x: &i32| {
            l2.lock().unwrap().push(*x * 10);
        });

        conditional.accept(&5);
        assert_eq!(*log.lock().unwrap(), vec![5]);

        conditional.accept(&-5);
        assert_eq!(*log.lock().unwrap(), vec![5, -50]);
    }

    #[test]
    fn test_box_conditional_accept() {
        let log = Arc::new(Mutex::new(Vec::new()));
        let l = log.clone();

        let consumer = BoxConsumer::new(move |x: &i32| {
            l.lock().unwrap().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);

        conditional.accept(&5);
        assert_eq!(*log.lock().unwrap(), vec![5]);

        conditional.accept(&-5);
        assert_eq!(*log.lock().unwrap(), vec![5]);
    }

    #[test]
    fn test_box_conditional_into_box() {
        let log = Arc::new(Mutex::new(Vec::new()));
        let l = log.clone();

        let consumer = BoxConsumer::new(move |x: &i32| {
            l.lock().unwrap().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let boxed = conditional.into_box();

        boxed.accept(&5);
        assert_eq!(*log.lock().unwrap(), vec![5]);

        boxed.accept(&-5);
        assert_eq!(*log.lock().unwrap(), vec![5]);
    }

    #[test]
    fn test_box_conditional_into_rc() {
        let log = Arc::new(Mutex::new(Vec::new()));
        let l = log.clone();

        let consumer = BoxConsumer::new(move |x: &i32| {
            l.lock().unwrap().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let rc = conditional.into_rc();

        rc.accept(&5);
        assert_eq!(*log.lock().unwrap(), vec![5]);

        rc.accept(&-5);
        assert_eq!(*log.lock().unwrap(), vec![5]);
    }

    #[test]
    fn test_box_conditional_into_fn() {
        let log = Arc::new(Mutex::new(Vec::new()));
        let l = log.clone();

        let consumer = BoxConsumer::new(move |x: &i32| {
            l.lock().unwrap().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let func = conditional.into_fn();

        func(&5);
        assert_eq!(*log.lock().unwrap(), vec![5]);

        func(&-5);
        assert_eq!(*log.lock().unwrap(), vec![5]);
    }
}

#[cfg(test)]
mod arc_conditional_consumer_tests {
    use super::*;
    use std::sync::atomic::{
        AtomicUsize,
        Ordering,
    };

    #[test]
    fn test_arc_conditional_and_then() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c1.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let chained = conditional.and_then(move |_x: &i32| {
            c2.fetch_add(10, Ordering::SeqCst);
        });

        chained.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 11);

        chained.accept(&-5);
        assert_eq!(counter.load(Ordering::SeqCst), 21);
    }

    #[test]
    fn test_arc_conditional_or_else() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c1 = counter.clone();
        let c2 = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c1.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0).or_else(move |_x: &i32| {
            c2.fetch_add(100, Ordering::SeqCst);
        });

        conditional.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        conditional.accept(&-5);
        assert_eq!(counter.load(Ordering::SeqCst), 101);
    }

    #[test]
    fn test_arc_conditional_accept() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);

        conditional.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        conditional.accept(&-5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);
    }

    #[test]
    fn test_arc_conditional_into_box() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let boxed = conditional.into_box();

        boxed.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        boxed.accept(&-5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);
    }

    #[test]
    fn test_arc_conditional_into_rc() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let rc = conditional.into_rc();

        rc.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        rc.accept(&-5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);
    }

    #[test]
    fn test_arc_conditional_into_arc() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let arc = conditional.into_arc();

        arc.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        arc.accept(&-5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);
    }

    #[test]
    fn test_arc_conditional_into_fn() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let func = conditional.into_fn();

        func(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        func(&-5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);
    }

    #[test]
    fn test_arc_conditional_to_box() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let boxed = conditional.to_box();

        boxed.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original conditional still usable
        conditional.accept(&10);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_arc_conditional_to_rc() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let rc = conditional.to_rc();

        rc.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original conditional still usable
        conditional.accept(&10);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_arc_conditional_to_arc() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let arc = conditional.to_arc();

        arc.accept(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original conditional still usable
        conditional.accept(&10);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }

    #[test]
    fn test_arc_conditional_to_fn() {
        let counter = Arc::new(AtomicUsize::new(0));
        let c = counter.clone();

        let consumer = ArcConsumer::new(move |_x: &i32| {
            c.fetch_add(1, Ordering::SeqCst);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let func = conditional.to_fn();

        func(&5);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original conditional still usable
        conditional.accept(&10);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }
}

#[cfg(test)]
mod rc_conditional_consumer_tests {
    use super::*;
    use std::cell::RefCell;

    #[test]
    fn test_rc_conditional_and_then() {
        let log = Rc::new(RefCell::new(Vec::new()));
        let l1 = log.clone();
        let l2 = log.clone();

        let consumer = RcConsumer::new(move |x: &i32| {
            l1.borrow_mut().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let chained = conditional.and_then(move |x: &i32| {
            l2.borrow_mut().push(*x * 2);
        });

        chained.accept(&5);
        assert_eq!(*log.borrow(), vec![5, 10]);

        chained.accept(&-5);
        assert_eq!(*log.borrow(), vec![5, 10, -10]);
    }

    #[test]
    fn test_rc_conditional_or_else() {
        let log = Rc::new(RefCell::new(Vec::new()));
        let l1 = log.clone();
        let l2 = log.clone();

        let consumer = RcConsumer::new(move |x: &i32| {
            l1.borrow_mut().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0).or_else(move |x: &i32| {
            l2.borrow_mut().push(*x * 10);
        });

        conditional.accept(&5);
        assert_eq!(*log.borrow(), vec![5]);

        conditional.accept(&-5);
        assert_eq!(*log.borrow(), vec![5, -50]);
    }

    #[test]
    fn test_rc_conditional_accept() {
        let log = Rc::new(RefCell::new(Vec::new()));
        let l = log.clone();

        let consumer = RcConsumer::new(move |x: &i32| {
            l.borrow_mut().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);

        conditional.accept(&5);
        assert_eq!(*log.borrow(), vec![5]);

        conditional.accept(&-5);
        assert_eq!(*log.borrow(), vec![5]);
    }

    #[test]
    fn test_rc_conditional_into_box() {
        let log = Rc::new(RefCell::new(Vec::new()));
        let l = log.clone();

        let consumer = RcConsumer::new(move |x: &i32| {
            l.borrow_mut().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let boxed = conditional.into_box();

        boxed.accept(&5);
        assert_eq!(*log.borrow(), vec![5]);

        boxed.accept(&-5);
        assert_eq!(*log.borrow(), vec![5]);
    }

    #[test]
    fn test_rc_conditional_into_rc() {
        let log = Rc::new(RefCell::new(Vec::new()));
        let l = log.clone();

        let consumer = RcConsumer::new(move |x: &i32| {
            l.borrow_mut().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let rc = conditional.into_rc();

        rc.accept(&5);
        assert_eq!(*log.borrow(), vec![5]);

        rc.accept(&-5);
        assert_eq!(*log.borrow(), vec![5]);
    }

    #[test]
    fn test_rc_conditional_into_fn() {
        let log = Rc::new(RefCell::new(Vec::new()));
        let l = log.clone();

        let consumer = RcConsumer::new(move |x: &i32| {
            l.borrow_mut().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let func = conditional.into_fn();

        func(&5);
        assert_eq!(*log.borrow(), vec![5]);

        func(&-5);
        assert_eq!(*log.borrow(), vec![5]);
    }

    #[test]
    fn test_rc_conditional_to_box() {
        let log = Rc::new(RefCell::new(Vec::new()));
        let l = log.clone();

        let consumer = RcConsumer::new(move |x: &i32| {
            l.borrow_mut().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let boxed = conditional.to_box();

        boxed.accept(&5);
        assert_eq!(*log.borrow(), vec![5]);

        // Original conditional still usable
        conditional.accept(&10);
        assert_eq!(*log.borrow(), vec![5, 10]);
    }

    #[test]
    fn test_rc_conditional_to_rc() {
        let log = Rc::new(RefCell::new(Vec::new()));
        let l = log.clone();

        let consumer = RcConsumer::new(move |x: &i32| {
            l.borrow_mut().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let rc = conditional.to_rc();

        rc.accept(&5);
        assert_eq!(*log.borrow(), vec![5]);

        // Original conditional still usable
        conditional.accept(&10);
        assert_eq!(*log.borrow(), vec![5, 10]);
    }

    #[test]
    fn test_rc_conditional_to_fn() {
        let log = Rc::new(RefCell::new(Vec::new()));
        let l = log.clone();

        let consumer = RcConsumer::new(move |x: &i32| {
            l.borrow_mut().push(*x);
        });

        let conditional = consumer.when(|x: &i32| *x > 0);
        let func = conditional.to_fn();

        func(&5);
        assert_eq!(*log.borrow(), vec![5]);

        // Original conditional still usable
        conditional.accept(&10);
        assert_eq!(*log.borrow(), vec![5, 10]);
    }
}