qubit-function 0.8.1

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

//! Comprehensive tests for StatefulFunction trait and its implementations

#![allow(unused_assignments)]

use std::cell::RefCell;
use std::rc::Rc;
use std::sync::{
    Arc,
    Mutex,
};

use qubit_function::{
    ArcPredicate,
    ArcStatefulFunction,
    BoxPredicate,
    BoxStatefulFunction,
    FunctionOnce,
    RcPredicate,
    RcStatefulFunction,
    StatefulFunction,
};

// ============================================================================
// StatefulFunction Trait Tests - Core Functionality
// ============================================================================

#[test]
fn test_stateful_function_trait_apply() {
    // Test that StatefulFunction trait's apply method works correctly

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    };
    assert_eq!(func.clone().apply(&10), 10);
    assert_eq!(func.clone().apply(&10), 11);
    assert_eq!(func.apply(&10), 12);
}

#[test]
fn test_stateful_function_trait_into_box() {
    // Test conversion from closure to BoxStatefulFunction

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    };
    let mut boxed = StatefulFunction::into_box(func);
    assert_eq!(boxed.apply(&10), 10);
    assert_eq!(boxed.apply(&10), 11);
}

#[test]
fn test_stateful_function_trait_into_rc() {
    // Test conversion from closure to RcStatefulFunction

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    };
    let mut rc = func.into_rc();
    assert_eq!(rc.apply(&10), 10);
    assert_eq!(rc.apply(&10), 11);
}

#[test]
fn test_stateful_function_trait_into_arc() {
    // Test conversion from closure to ArcStatefulFunction

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    };
    let mut arc = func.into_arc();
    assert_eq!(arc.apply(&10), 10);
    assert_eq!(arc.apply(&10), 11);
}

#[test]
fn test_stateful_function_trait_into_fn() {
    // Test conversion to closure

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    };
    let mut closure = StatefulFunction::into_fn(func);
    assert_eq!(closure(&10), 10);
    assert_eq!(closure(&10), 11);
}

#[test]
fn test_stateful_function_trait_to_box() {
    // Test non-consuming conversion to BoxStatefulFunction

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    };
    let mut boxed = StatefulFunction::to_box(&func);
    assert_eq!(boxed.apply(&10), 10);
    assert_eq!(boxed.apply(&10), 11);
}

#[test]
fn test_stateful_function_trait_to_rc() {
    // Test non-consuming conversion to RcStatefulFunction

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    };
    let mut rc = func.to_rc();
    assert_eq!(rc.apply(&10), 10);
    assert_eq!(rc.apply(&10), 11);
}

#[test]
fn test_stateful_function_trait_to_arc() {
    // Test non-consuming conversion to ArcStatefulFunction

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    };
    let mut arc = func.to_arc();
    assert_eq!(arc.apply(&10), 10);
    assert_eq!(arc.apply(&10), 11);
}

#[test]
fn test_stateful_function_trait_to_fn() {
    // Test non-consuming conversion to closure

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    };
    let mut closure = StatefulFunction::to_fn(&func);
    assert_eq!(closure(&10), 10);
    assert_eq!(closure(&10), 11);
}

#[test]
fn test_stateful_function_trait_into_once() {
    // Test consuming conversion to BoxFunctionOnce

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    };

    let once_func = func.into_once();
    assert_eq!(once_func.apply(&10), 10);
}

#[test]
fn test_stateful_function_trait_to_once() {
    // Test non-consuming conversion to BoxFunctionOnce

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    };

    let once_func = func.to_once();
    assert_eq!(once_func.apply(&10), 10);
    // Note: Original func is consumed by to_once since it calls clone().into_once()
}

// ============================================================================
// BoxStatefulFunction Tests - Constructor and Basic Operations
// ============================================================================

#[test]
fn test_box_stateful_function_new() {
    // Test BoxStatefulFunction::new with simple closure

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    assert_eq!(func.apply(&10), 10);
    assert_eq!(func.apply(&10), 11);
    assert_eq!(func.apply(&10), 12);
}

#[test]
fn test_box_stateful_function_identity() {
    // Test BoxStatefulFunction::identity
    let mut identity = BoxStatefulFunction::<i32, i32>::identity();
    assert_eq!(identity.apply(&42), 42);
    assert_eq!(identity.apply(&0), 0);
    assert_eq!(identity.apply(&-100), -100);
}

#[test]
fn test_box_stateful_function_constant() {
    // Test BoxStatefulFunction::constant
    let mut constant = BoxStatefulFunction::constant("hello");
    assert_eq!(constant.apply(&123), "hello");
    assert_eq!(constant.apply(&456), "hello");
    assert_eq!(constant.apply(&0), "hello");
}

#[test]
fn test_box_stateful_function_apply() {
    // Test StatefulFunction trait implementation for BoxStatefulFunction

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x * current
    });
    assert_eq!(func.apply(&10), 0);
    assert_eq!(func.apply(&10), 10);
    assert_eq!(func.apply(&10), 20);
}

// ============================================================================
// BoxStatefulFunction Tests - Composition Methods
// ============================================================================

#[test]
fn test_box_stateful_function_and_then() {
    // Test BoxStatefulFunction::and_then composition
    let mut counter1 = 0;
    let func1 = BoxStatefulFunction::new(move |x: &i32| {
        counter1 += 1;
        x + counter1
    });

    let mut counter2 = 0;
    let func2 = BoxStatefulFunction::new(move |x: &i32| {
        counter2 += 1;
        x * counter2
    });

    let mut composed = func1.and_then(func2);
    assert_eq!(composed.apply(&10), 11); // (10 + 1) * 1
    assert_eq!(composed.apply(&10), 24); // (10 + 2) * 2
}

// ============================================================================
// BoxStatefulFunction Tests - Conditional Execution
// ============================================================================

#[test]
fn test_box_stateful_function_when_or_else() {
    // Test conditional execution with when/or_else
    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        *counter_clone.borrow_mut() += 1;
        x * 2
    })
    .when(|x: &i32| *x > 10)
    .or_else(|x: &i32| x + 1);

    assert_eq!(func.apply(&15), 30); // 15 > 10, apply * 2
    assert_eq!(func.apply(&5), 6); // 5 <= 10, apply + 1
    assert_eq!(*counter.borrow(), 1); // Only the first call satisfies the condition
}

#[test]
fn test_box_stateful_function_when_with_predicate() {
    // Test when with BoxPredicate

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x * current
    })
    .when(BoxPredicate::new(|x: &i32| *x > 0))
    .or_else(|x: &i32| -(*x));

    assert_eq!(func.apply(&10), 0); // 10 > 0, apply * 0
    assert_eq!(func.apply(&-5), 5); // -5 <= 0, apply negate
}

// ============================================================================
// BoxStatefulFunction Tests - Type Conversions
// ============================================================================

#[test]
fn test_box_stateful_function_into_box() {
    // Test BoxStatefulFunction::into_box (should return itself)

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = BoxStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    let mut boxed = func.into_box();
    assert_eq!(boxed.apply(&10), 10);
}

#[test]
fn test_box_stateful_function_into_rc() {
    // Test BoxStatefulFunction::into_rc conversion

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = BoxStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    let mut rc = func.into_rc();
    assert_eq!(rc.apply(&10), 10);
}

#[test]
fn test_box_stateful_function_into_fn() {
    // Test BoxStatefulFunction::into_fn conversion

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = BoxStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    let mut closure = func.into_fn();
    assert_eq!(closure(&10), 10);
}

// ============================================================================
// ArcStatefulFunction Tests - Constructor and Basic Operations
// ============================================================================

#[test]
fn test_arc_stateful_function_new() {
    // Test ArcStatefulFunction::new with simple closure

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let mut func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    assert_eq!(func.apply(&10), 10);
    assert_eq!(func.apply(&10), 11);
    assert_eq!(func.apply(&10), 12);
}

#[test]
fn test_arc_stateful_function_identity() {
    // Test ArcStatefulFunction::identity
    let mut identity = ArcStatefulFunction::<i32, i32>::identity();
    assert_eq!(identity.apply(&42), 42);
    assert_eq!(identity.apply(&0), 0);
    assert_eq!(identity.apply(&-100), -100);
}

#[test]
fn test_arc_stateful_function_constant() {
    // Test ArcStatefulFunction::constant
    let mut constant = ArcStatefulFunction::constant("hello");
    assert_eq!(constant.apply(&123), "hello");
    assert_eq!(constant.apply(&456), "hello");
}

#[test]
fn test_arc_stateful_function_apply() {
    // Test StatefulFunction trait implementation for ArcStatefulFunction

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let mut func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x * *current;
        *current += 1;
        result
    });
    assert_eq!(func.apply(&10), 0);
    assert_eq!(func.apply(&10), 10);
}

#[test]
fn test_arc_stateful_function_clone() {
    // Test ArcStatefulFunction::clone

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut func_clone = func.clone();
    assert_eq!(func_clone.apply(&10), 10);
    assert_eq!(func_clone.apply(&10), 11);
}

// ============================================================================
// ArcStatefulFunction Tests - Composition Methods
// ============================================================================

#[test]
fn test_arc_stateful_function_and_then() {
    // Test ArcStatefulFunction::and_then composition
    let mut counter1 = 0;
    let func1 = ArcStatefulFunction::new(move |x: &i32| {
        counter1 += 1;
        x + counter1
    });

    let mut counter2 = 0;
    let func2 = ArcStatefulFunction::new(move |x: &i32| {
        counter2 += 1;
        x * counter2
    });

    let mut composed = func1.and_then(func2);
    assert_eq!(composed.apply(&10), 11); // (10 + 1) * 1
    assert_eq!(composed.apply(&10), 24); // (10 + 2) * 2
}

// ============================================================================
// ArcStatefulFunction Tests - Conditional Execution
// ============================================================================

#[test]
fn test_arc_stateful_function_when_or_else() {
    // Test conditional execution with when/or_else
    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let mut func = ArcStatefulFunction::new(move |x: &i32| {
        *counter_clone.lock().unwrap() += 1;
        x * 2
    })
    .when(|x: &i32| *x > 10)
    .or_else(|x: &i32| x + 1);

    assert_eq!(func.apply(&15), 30); // 15 > 10, apply * 2
    assert_eq!(func.apply(&5), 6); // 5 <= 10, apply + 1
    assert_eq!(*counter.lock().unwrap(), 1); // Only the first call satisfies the condition
}

#[test]
fn test_arc_stateful_function_when_with_predicate() {
    // Test when with ArcPredicate

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let mut func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x * *current;
        *current += 1;
        result
    })
    .when(ArcPredicate::new(|x: &i32| *x > 0))
    .or_else(|x: &i32| -(*x));

    assert_eq!(func.apply(&10), 0); // 10 > 0, apply * 0
    assert_eq!(func.apply(&-5), 5); // -5 <= 0, apply negate
}

// ============================================================================
// ArcStatefulFunction Tests - Type Conversions
// ============================================================================

#[test]
fn test_arc_stateful_function_into_box() {
    // Test ArcStatefulFunction::into_box conversion

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut boxed = func.into_box();
    assert_eq!(boxed.apply(&10), 10);
}

#[test]
fn test_arc_stateful_function_into_rc() {
    // Test ArcStatefulFunction::into_rc conversion

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut rc = func.into_rc();
    assert_eq!(rc.apply(&10), 10);
}

#[test]
fn test_arc_stateful_function_into_arc() {
    // Test ArcStatefulFunction::into_arc (should return itself)

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut arc = func.into_arc();
    assert_eq!(arc.apply(&10), 10);
}

#[test]
fn test_arc_stateful_function_into_fn() {
    // Test ArcStatefulFunction::into_fn conversion

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut closure = func.into_fn();
    assert_eq!(closure(&10), 10);
}

#[test]
fn test_arc_stateful_function_to_box() {
    // Test non-consuming conversion to BoxStatefulFunction

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut boxed = func.to_box();
    assert_eq!(boxed.apply(&10), 10);
    assert_eq!(func.clone().apply(&10), 11);
}

#[test]
fn test_arc_stateful_function_to_rc() {
    // Test non-consuming conversion to RcStatefulFunction

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut rc = func.to_rc();
    assert_eq!(rc.apply(&10), 10);
    assert_eq!(func.clone().apply(&10), 11);
}

#[test]
fn test_arc_stateful_function_to_arc() {
    // Test non-consuming conversion to ArcStatefulFunction (clone)

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut arc = func.to_arc();
    assert_eq!(arc.apply(&10), 10);
    assert_eq!(func.clone().apply(&10), 11);
}

#[test]
fn test_arc_stateful_function_to_fn() {
    // Test non-consuming conversion to closure

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut closure = func.to_fn();
    assert_eq!(closure(&10), 10);
    assert_eq!(func.clone().apply(&10), 11);
}

// ============================================================================
// ArcStatefulFunction Tests - Thread Safety
// ============================================================================

#[test]
fn test_arc_stateful_function_thread_safety() {
    // Test that ArcStatefulFunction is Send + Sync

    let counter = Arc::new(Mutex::new(0));
    let counter_clone = Arc::clone(&counter);
    let func = ArcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.lock().unwrap();
        let result = x + *current;
        *current += 1;
        result
    });
    let mut func_clone = func.clone();

    let handle = std::thread::spawn(move || func_clone.apply(&10));

    assert_eq!(handle.join().unwrap(), 10);
}

// ============================================================================
// RcStatefulFunction Tests - Constructor and Basic Operations
// ============================================================================

#[test]
fn test_rc_stateful_function_new() {
    // Test RcStatefulFunction::new with simple closure

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = RcStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    assert_eq!(func.apply(&10), 10);
    assert_eq!(func.apply(&10), 11);
    assert_eq!(func.apply(&10), 12);
}

#[test]
fn test_rc_stateful_function_identity() {
    // Test RcStatefulFunction::identity
    let mut identity = RcStatefulFunction::<i32, i32>::identity();
    assert_eq!(identity.apply(&42), 42);
    assert_eq!(identity.apply(&0), 0);
    assert_eq!(identity.apply(&-100), -100);
}

#[test]
fn test_rc_stateful_function_constant() {
    // Test RcStatefulFunction::constant
    let mut constant = RcStatefulFunction::constant("hello");
    assert_eq!(constant.apply(&123), "hello");
    assert_eq!(constant.apply(&456), "hello");
}

#[test]
fn test_rc_stateful_function_apply() {
    // Test StatefulFunction trait implementation for RcStatefulFunction

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = RcStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x * current
    });
    assert_eq!(func.apply(&10), 0);
    assert_eq!(func.apply(&10), 10);
}

#[test]
fn test_rc_stateful_function_clone() {
    // Test RcStatefulFunction::clone

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = RcStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    let mut func_clone = func.clone();
    assert_eq!(func_clone.apply(&10), 10);
    assert_eq!(func_clone.apply(&10), 11);
}

// ============================================================================
// RcStatefulFunction Tests - Composition Methods
// ============================================================================

#[test]
fn test_rc_stateful_function_and_then() {
    // Test RcStatefulFunction::and_then composition
    let mut counter1 = 0;
    let func1 = RcStatefulFunction::new(move |x: &i32| {
        counter1 += 1;
        x + counter1
    });

    let mut counter2 = 0;
    let func2 = RcStatefulFunction::new(move |x: &i32| {
        counter2 += 1;
        x * counter2
    });

    let mut composed = func1.and_then(func2);
    assert_eq!(composed.apply(&10), 11); // (10 + 1) * 1
    assert_eq!(composed.apply(&10), 24); // (10 + 2) * 2
}

// ============================================================================
// RcStatefulFunction Tests - Conditional Execution
// ============================================================================

#[test]
fn test_rc_stateful_function_when_or_else() {
    // Test conditional execution with when/or_else
    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = RcStatefulFunction::new(move |x: &i32| {
        *counter_clone.borrow_mut() += 1;
        x * 2
    })
    .when(|x: &i32| *x > 10)
    .or_else(|x: &i32| x + 1);

    assert_eq!(func.apply(&15), 30); // 15 > 10, apply * 2
    assert_eq!(func.apply(&5), 6); // 5 <= 10, apply + 1
    assert_eq!(*counter.borrow(), 1); // Only the first call satisfies the condition
}

#[test]
fn test_rc_stateful_function_when_with_predicate() {
    // Test when with RcPredicate

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = RcStatefulFunction::new(move |x: &i32| {
        let mut current = counter_clone.borrow_mut();
        let result = x * *current;
        *current += 1;
        result
    })
    .when(RcPredicate::new(|x: &i32| *x > 0))
    .or_else(|x: &i32| -(*x));

    assert_eq!(func.apply(&10), 0); // 10 > 0, apply * 0
    assert_eq!(func.apply(&-5), 5); // -5 <= 0, apply negate
}

// ============================================================================
// RcStatefulFunction Tests - Type Conversions
// ============================================================================

#[test]
fn test_rc_stateful_function_into_box() {
    // Test RcStatefulFunction::into_box conversion

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = RcStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    let mut boxed = func.into_box();
    assert_eq!(boxed.apply(&10), 10);
}

#[test]
fn test_rc_stateful_function_into_rc() {
    // Test RcStatefulFunction::into_rc (should return itself)

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = RcStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    let mut rc = func.into_rc();
    assert_eq!(rc.apply(&10), 10);
}

#[test]
fn test_rc_stateful_function_into_fn() {
    // Test RcStatefulFunction::into_fn conversion

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = RcStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    let mut closure = func.into_fn();
    assert_eq!(closure(&10), 10);
}

#[test]
fn test_rc_stateful_function_to_box() {
    // Test RcStatefulFunction::to_box conversion

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = RcStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    let mut boxed = func.to_box();
    assert_eq!(boxed.apply(&10), 10);
    // Original should still be usable since it was cloned
    assert_eq!(func.apply(&5), 6); // 5 + 1 = 6
}

#[test]
fn test_rc_stateful_function_to_rc() {
    // Test RcStatefulFunction::to_rc conversion (clone)

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = RcStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    let mut rc = func.to_rc();
    assert_eq!(rc.apply(&10), 10);
    // Original should still be usable since it was cloned
    assert_eq!(func.apply(&5), 6); // 5 + 1 = 6
}

#[test]
fn test_rc_stateful_function_to_fn() {
    // Test RcStatefulFunction::to_fn conversion

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = RcStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });

    // Test closure in a separate scope to avoid borrowing conflicts
    {
        let mut closure = func.to_fn();
        assert_eq!(closure(&10), 10);
    } // closure dropped here

    // Original should still be usable since it was cloned
    // Note: counter state is shared, so it continues from 1
    assert_eq!(func.apply(&5), 6); // 5 + 1 = 6
}

// ============================================================================
// Edge Cases and Boundary Tests
// ============================================================================

#[test]
fn test_stateful_function_with_zero() {
    // Test stateful function with zero input

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x + current
    });
    assert_eq!(func.apply(&0), 0);
    assert_eq!(func.apply(&0), 1);
}

#[test]
fn test_stateful_function_with_negative() {
    // Test stateful function with negative input

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        let current = *counter_clone.borrow();
        *counter_clone.borrow_mut() += 1;
        x * current
    });
    assert_eq!(func.apply(&-10), 0);
    assert_eq!(func.apply(&-10), -10);
}

#[test]
fn test_stateful_function_accumulator() {
    // Test stateful function as accumulator
    let mut sum = 0;
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        sum += *x;
        sum
    });
    assert_eq!(func.apply(&1), 1);
    assert_eq!(func.apply(&2), 3);
    assert_eq!(func.apply(&3), 6);
    assert_eq!(func.apply(&4), 10);
}

#[test]
fn test_stateful_function_with_string() {
    // Test stateful function with String type
    let mut buffer = String::new();
    let mut func = BoxStatefulFunction::new(move |s: &String| {
        buffer.push_str(s);
        buffer.clone()
    });
    assert_eq!(func.apply(&String::from("Hello")), "Hello");
    assert_eq!(func.apply(&String::from(" ")), "Hello ");
    assert_eq!(func.apply(&String::from("World")), "Hello World");
}

#[test]
fn test_stateful_function_with_vec() {
    // Test stateful function with Vec type
    let mut history = Vec::new();
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        history.push(*x);
        history.len()
    });
    assert_eq!(func.apply(&1), 1);
    assert_eq!(func.apply(&2), 2);
    assert_eq!(func.apply(&3), 3);
}

#[test]
fn test_stateful_function_counter() {
    // Test stateful function as simple counter
    let mut count = 0;
    let mut func = BoxStatefulFunction::new(move |_x: &i32| {
        count += 1;
        count
    });
    assert_eq!(func.apply(&0), 1);
    assert_eq!(func.apply(&0), 2);
    assert_eq!(func.apply(&0), 3);
}

#[test]
fn test_stateful_function_toggle() {
    // Test stateful function as toggle
    let mut toggle = false;
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        toggle = !toggle;
        if toggle {
            *x
        } else {
            -*x
        }
    });
    assert_eq!(func.apply(&5), 5);
    assert_eq!(func.apply(&5), -5);
    assert_eq!(func.apply(&5), 5);
}

// ============================================================================
// FnStatefulFunctionOps Extension Trait Tests
// ============================================================================

#[test]
fn test_fn_stateful_function_ops_and_then() {
    // Test FnStatefulFunctionOps::and_then for closures
    use qubit_function::FnStatefulFunctionOps;

    let mut counter1 = 0;
    let func1 = move |x: &i32| {
        counter1 += 1;
        x + counter1
    };

    let mut counter2 = 0;
    let func2 = move |x: &i32| {
        counter2 += 1;
        x * counter2
    };

    let mut composed = func1.and_then(func2);
    assert_eq!(composed.apply(&10), 11);
}

#[test]
fn test_fn_stateful_function_ops_when() {
    // Test FnStatefulFunctionOps::when for closures
    use qubit_function::FnStatefulFunctionOps;

    let counter = Rc::new(RefCell::new(0));
    let counter_clone = Rc::clone(&counter);
    let func = move |x: &i32| {
        *counter_clone.borrow_mut() += 1;
        x * 2
    };

    let mut conditional = func.when(|x: &i32| *x > 0).or_else(|x: &i32| -(*x));
    assert_eq!(conditional.apply(&5), 10); // 5 > 0, apply * 2
    assert_eq!(conditional.apply(&-5), 5); // -5 <= 0, apply -(*x) = -(-5) = 5
    assert_eq!(*counter.borrow(), 1); // Only the first call satisfies the condition
}

// ============================================================================
// Complex State Management Tests
// ============================================================================

#[test]
fn test_stateful_function_with_multiple_state() {
    // Test stateful function with multiple state variables
    let mut count = 0;
    let mut sum = 0;
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        count += 1;
        sum += *x;
        (count, sum)
    });
    assert_eq!(func.apply(&10), (1, 10));
    assert_eq!(func.apply(&20), (2, 30));
    assert_eq!(func.apply(&30), (3, 60));
}

#[test]
fn test_stateful_function_with_option_state() {
    // Test stateful function with Option state
    let mut last_value: Option<i32> = None;
    let mut func = BoxStatefulFunction::new(move |x: &i32| {
        let result = last_value.unwrap_or(0) + *x;
        last_value = Some(*x);
        result
    });
    assert_eq!(func.apply(&10), 10);
    assert_eq!(func.apply(&20), 30);
    assert_eq!(func.apply(&30), 50);
}

// ============================================================================
// Custom Struct Tests - StatefulFunction Default Implementation
// ============================================================================

/// Custom struct for testing StatefulFunction trait default implementations
#[derive(Clone)]
struct CustomStatefulFunction {
    multiplier: i32,
}

// Implement Send and Sync for CustomStatefulFunction to support Arc
unsafe impl Send for CustomStatefulFunction {}
unsafe impl Sync for CustomStatefulFunction {}

impl StatefulFunction<i32, i32> for CustomStatefulFunction {
    fn apply(&mut self, input: &i32) -> i32 {
        self.multiplier += 1;
        input * self.multiplier
    }
}

#[test]
fn test_custom_stateful_function_into_box() {
    // Test default implementation of into_box() for custom struct
    let custom = CustomStatefulFunction { multiplier: 0 };
    let mut boxed = custom.into_box();
    assert_eq!(boxed.apply(&10), 10); // 10 * 1
    assert_eq!(boxed.apply(&10), 20); // 10 * 2
    assert_eq!(boxed.apply(&10), 30); // 10 * 3
}

#[test]
fn test_custom_stateful_function_into_rc() {
    // Test default implementation of into_rc() for custom struct
    let custom = CustomStatefulFunction { multiplier: 0 };
    let mut rc = custom.into_rc();
    assert_eq!(rc.apply(&10), 10); // 10 * 1
    assert_eq!(rc.apply(&10), 20); // 10 * 2
    assert_eq!(rc.apply(&10), 30); // 10 * 3
}

#[test]
fn test_custom_stateful_function_into_arc() {
    // Test default implementation of into_arc() for custom struct
    let custom = CustomStatefulFunction { multiplier: 0 };
    let mut arc = custom.into_arc();
    assert_eq!(arc.apply(&10), 10); // 10 * 1
    assert_eq!(arc.apply(&10), 20); // 10 * 2
    assert_eq!(arc.apply(&10), 30); // 10 * 3
}

#[test]
fn test_custom_stateful_function_into_fn() {
    // Test default implementation of into_fn() for custom struct
    let custom = CustomStatefulFunction { multiplier: 0 };
    let mut func = custom.into_fn();
    assert_eq!(func(&10), 10); // 10 * 1
    assert_eq!(func(&10), 20); // 10 * 2
    assert_eq!(func(&10), 30); // 10 * 3
}

#[test]
fn test_custom_stateful_function_to_box() {
    // Test default implementation of to_box() for custom struct
    let custom = CustomStatefulFunction { multiplier: 0 };
    let mut boxed = custom.to_box();
    assert_eq!(boxed.apply(&10), 10); // 10 * 1
    assert_eq!(boxed.apply(&10), 20); // 10 * 2
                                      // Original custom is still usable (was cloned)
    let mut custom_clone = custom.clone();
    assert_eq!(custom_clone.apply(&10), 10); // 10 * 1 (independent state)
}

#[test]
fn test_custom_stateful_function_to_rc() {
    // Test default implementation of to_rc() for custom struct
    let custom = CustomStatefulFunction { multiplier: 0 };
    let mut rc = custom.to_rc();
    assert_eq!(rc.apply(&10), 10); // 10 * 1
    assert_eq!(rc.apply(&10), 20); // 10 * 2
                                   // Original custom is still usable (was cloned)
    let mut custom_clone = custom.clone();
    assert_eq!(custom_clone.apply(&10), 10); // 10 * 1 (independent state)
}

#[test]
fn test_custom_stateful_function_to_arc() {
    // Test default implementation of to_arc() for custom struct
    let custom = CustomStatefulFunction { multiplier: 0 };
    let mut arc = custom.to_arc();
    assert_eq!(arc.apply(&10), 10); // 10 * 1
    assert_eq!(arc.apply(&10), 20); // 10 * 2
                                    // Original custom is still usable (was cloned)
    let mut custom_clone = custom.clone();
    assert_eq!(custom_clone.apply(&10), 10); // 10 * 1 (independent state)
}

#[test]
fn test_custom_stateful_function_to_fn() {
    // Test default implementation of to_fn() for custom struct
    let custom = CustomStatefulFunction { multiplier: 0 };
    let mut func = custom.to_fn();
    assert_eq!(func(&10), 10); // 10 * 1
    assert_eq!(func(&10), 20); // 10 * 2
                               // Original custom is still usable (was cloned)
    let mut custom_clone = custom.clone();
    assert_eq!(custom_clone.apply(&10), 10); // 10 * 1 (independent state)
}

// ============================================================================
// ArcConditionalStatefulFunction Clone Tests
// ============================================================================

#[test]
fn test_arc_conditional_stateful_function_clone() {
    // Test that ArcConditionalStatefulFunction can be cloned
    let counter = Arc::new(Mutex::new(0));
    let counter_clone = counter.clone();
    let conditional = ArcStatefulFunction::new(move |x: &i32| {
        *counter_clone.lock().unwrap() += 1;
        x * 2
    })
    .when(|x: &i32| *x > 10);

    // Clone the conditional function before calling or_else
    let clone1 = conditional.clone();
    let clone2 = conditional.clone();

    // Convert to complete functions using or_else
    let mut func = conditional.or_else(|x: &i32| x + 1);
    let mut func_clone1 = clone1.or_else(|x: &i32| x + 1);
    let mut func_clone2 = clone2.or_else(|x: &i32| x + 1);

    // Test that all instances work independently but share the same counter
    assert_eq!(func.apply(&15), 30); // 15 > 10, apply * 2
    assert_eq!(*counter.lock().unwrap(), 1);

    assert_eq!(func_clone1.apply(&20), 40); // 20 > 10, apply * 2
    assert_eq!(*counter.lock().unwrap(), 2);

    assert_eq!(func_clone2.apply(&5), 6); // 5 <= 10, apply + 1
    assert_eq!(*counter.lock().unwrap(), 2); // Counter not incremented

    assert_eq!(func_clone2.apply(&12), 24); // 12 > 10, apply * 2
    assert_eq!(*counter.lock().unwrap(), 3);
}

// ============================================================================
// RcConditionalStatefulFunction Clone Tests
// ============================================================================

#[test]
fn test_rc_conditional_stateful_function_clone() {
    // Test that RcConditionalStatefulFunction can be cloned
    let counter = Rc::new(RefCell::new(0));
    let counter_clone = counter.clone();
    let conditional = RcStatefulFunction::new(move |x: &i32| {
        *counter_clone.borrow_mut() += 1;
        x * 2
    })
    .when(|x: &i32| *x > 10);

    // Clone the conditional function before calling or_else
    let clone1 = conditional.clone();
    let clone2 = conditional.clone();

    // Convert to complete functions using or_else
    let mut func = conditional.or_else(|x: &i32| x + 1);
    let mut func_clone1 = clone1.or_else(|x: &i32| x + 1);
    let mut func_clone2 = clone2.or_else(|x: &i32| x + 1);

    // Test that all instances work independently but share the same counter
    assert_eq!(func.apply(&15), 30); // 15 > 10, apply * 2
    assert_eq!(*counter.borrow(), 1);

    assert_eq!(func_clone1.apply(&20), 40); // 20 > 10, apply * 2
    assert_eq!(*counter.borrow(), 2);

    assert_eq!(func_clone2.apply(&5), 6); // 5 <= 10, apply + 1
    assert_eq!(*counter.borrow(), 2); // Counter not incremented

    assert_eq!(func_clone2.apply(&12), 24); // 12 > 10, apply * 2
    assert_eq!(*counter.borrow(), 3);
}

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

// Allow unused variables in debug/display tests since they are used in closures
#[allow(unused_variables)]
#[test]
fn test_box_stateful_function_debug_display() {
    // Test Debug and Display for BoxStatefulFunction without name

    let mut double = BoxStatefulFunction::new(move |x: &i32| x * 2);
    // Call apply to test the function
    let _result1 = double.apply(&5);

    let debug_str = format!("{:?}", double);
    assert!(debug_str.contains("BoxStatefulFunction"));
    assert!(debug_str.contains("name"));
    assert!(debug_str.contains("function"));

    let display_str = format!("{}", double);
    assert_eq!(display_str, "BoxStatefulFunction");

    // Test Debug and Display for BoxStatefulFunction with name
    let mut named_double = BoxStatefulFunction::new_with_name("stateful_double", |x: &i32| x * 2);
    // Call apply to test the function
    let _result2 = named_double.apply(&3);

    let named_debug_str = format!("{:?}", named_double);
    assert!(named_debug_str.contains("BoxStatefulFunction"));
    assert!(named_debug_str.contains("name"));
    assert!(named_debug_str.contains("function"));

    let named_display_str = format!("{}", named_double);
    assert_eq!(named_display_str, "BoxStatefulFunction(stateful_double)");
}

// Allow unused variables in debug/display tests since they are used in closures
#[allow(unused_variables)]
#[test]
fn test_rc_stateful_function_debug_display() {
    // Test Debug and Display for RcStatefulFunction without name

    let mut double = RcStatefulFunction::new(move |x: &i32| x * 2);
    // Call apply to test the function
    let _result1 = double.apply(&5);

    let debug_str = format!("{:?}", double);
    assert!(debug_str.contains("RcStatefulFunction"));
    assert!(debug_str.contains("name"));
    assert!(debug_str.contains("function"));

    let display_str = format!("{}", double);
    assert_eq!(display_str, "RcStatefulFunction");

    // Test Debug and Display for RcStatefulFunction with name
    let mut named_double = RcStatefulFunction::new_with_name("rc_stateful_double", |x: &i32| x * 2);
    // Call apply to test the function
    let _result2 = named_double.apply(&3);

    let named_debug_str = format!("{:?}", named_double);
    assert!(named_debug_str.contains("RcStatefulFunction"));
    assert!(named_debug_str.contains("name"));
    assert!(named_debug_str.contains("function"));

    let named_display_str = format!("{}", named_double);
    assert_eq!(named_display_str, "RcStatefulFunction(rc_stateful_double)");
}

// Allow unused variables in debug/display tests since they are used in closures
#[allow(unused_variables)]
#[test]
fn test_arc_stateful_function_debug_display() {
    // Test Debug and Display for ArcStatefulFunction without name

    let mut double = ArcStatefulFunction::new(move |x: &i32| x * 2);
    // Call apply to test the function
    let _result1 = double.apply(&5);

    let debug_str = format!("{:?}", double);
    assert!(debug_str.contains("ArcStatefulFunction"));
    assert!(debug_str.contains("name"));
    assert!(debug_str.contains("function"));

    let display_str = format!("{}", double);
    assert_eq!(display_str, "ArcStatefulFunction");

    // Test Debug and Display for ArcStatefulFunction with name
    let mut counter2 = 0;
    let mut named_double =
        ArcStatefulFunction::new_with_name("arc_stateful_double", move |x: &i32| {
            counter2 += 1;
            x * 2
        });
    // Call apply to test the function
    let _result2 = named_double.apply(&3);

    let named_debug_str = format!("{:?}", named_double);
    assert!(named_debug_str.contains("ArcStatefulFunction"));
    assert!(named_debug_str.contains("name"));
    assert!(named_debug_str.contains("function"));

    let named_display_str = format!("{}", named_double);
    assert_eq!(
        named_display_str,
        "ArcStatefulFunction(arc_stateful_double)"
    );
}

// ============================================================================
// StatefulFunction Name Management Tests
// ============================================================================

// Allow unused variables in tests since they are used in closures
#[allow(unused_variables)]
#[test]
fn test_box_stateful_function_name_methods() {
    // Test new_with_name, name(), and set_name()

    let mut double = BoxStatefulFunction::new_with_name("box_stateful_func", move |x: &i32| x * 2);

    // Test name() returns the initial name
    assert_eq!(double.name(), Some("box_stateful_func"));

    // Test set_name() changes the name
    double.set_name("modified_box_stateful");
    assert_eq!(double.name(), Some("modified_box_stateful"));

    // Test that function still works after name change
    assert_eq!(double.apply(&5), 10);
}

// Allow unused variables in tests since they are used in closures
#[allow(unused_variables)]
#[test]
fn test_rc_stateful_function_name_methods() {
    // Test new_with_name, name(), and set_name()

    let mut double = RcStatefulFunction::new_with_name("rc_stateful_func", move |x: &i32| x * 2);

    // Test name() returns the initial name
    assert_eq!(double.name(), Some("rc_stateful_func"));

    // Test set_name() changes the name
    double.set_name("modified_rc_stateful");
    assert_eq!(double.name(), Some("modified_rc_stateful"));

    // Test that function still works after name change
    assert_eq!(double.apply(&5), 10);

    // Test cloning preserves name
    let mut cloned = double.clone();
    assert_eq!(cloned.name(), Some("modified_rc_stateful"));
    assert_eq!(cloned.apply(&3), 6);
}

// Allow unused variables in tests since they are used in closures
#[allow(unused_variables)]
#[test]
fn test_arc_stateful_function_name_methods() {
    // Test new_with_name, name(), and set_name()

    let mut double = ArcStatefulFunction::new_with_name("arc_stateful_func", move |x: &i32| x * 2);

    // Test name() returns the initial name
    assert_eq!(double.name(), Some("arc_stateful_func"));

    // Test set_name() changes the name
    double.set_name("modified_arc_stateful");
    assert_eq!(double.name(), Some("modified_arc_stateful"));

    // Test that function still works after name change
    assert_eq!(double.apply(&5), 10);

    // Test cloning preserves name
    let mut cloned = double.clone();
    assert_eq!(cloned.name(), Some("modified_arc_stateful"));
    assert_eq!(cloned.apply(&3), 6);
}

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

// Allow unused variables in debug/display tests since they are used in closures
#[allow(unused_variables)]
#[test]
fn test_box_conditional_stateful_function_debug_display() {
    // Test Debug and Display for BoxConditionalStatefulFunction without name

    let mut double = BoxStatefulFunction::new(move |x: &i32| x * 2);
    // Call apply to test the function
    let _result1 = double.apply(&5);

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

    let debug_str = format!("{:?}", conditional);
    assert!(debug_str.contains("BoxConditionalStatefulFunction"));
    assert!(debug_str.contains("name"));
    assert!(debug_str.contains("function"));
    assert!(debug_str.contains("predicate"));

    let display_str = format!("{}", conditional);
    assert!(display_str.starts_with("BoxConditionalStatefulFunction("));
    assert!(display_str.contains("BoxStatefulFunction"));
    assert!(display_str.contains("BoxPredicate"));
    assert!(display_str.ends_with(")"));

    // Test Debug and Display for BoxConditionalStatefulFunction with name
    let mut counter2 = 0;
    let mut named_double = BoxStatefulFunction::new_with_name("stateful_double", move |x: &i32| {
        counter2 += 1;
        x * 2
    });
    // Call apply to test the function
    let _result2 = named_double.apply(&3);

    let named_conditional = named_double.when(|x: &i32| *x % 2 == 0);

    let named_debug_str = format!("{:?}", named_conditional);
    assert!(named_debug_str.contains("BoxConditionalStatefulFunction"));
    assert!(named_debug_str.contains("name"));
    assert!(named_debug_str.contains("function"));
    assert!(named_debug_str.contains("predicate"));

    let named_display_str = format!("{}", named_conditional);
    assert!(named_display_str.starts_with("BoxConditionalStatefulFunction("));
    assert!(named_display_str.contains("BoxStatefulFunction(stateful_double)"));
    assert!(named_display_str.contains("BoxPredicate"));
    assert!(named_display_str.ends_with(")"));
}

// Allow unused variables in debug/display tests since they are used in closures
#[allow(unused_variables)]
#[test]
fn test_rc_conditional_stateful_function_debug_display() {
    // Test Debug and Display for RcConditionalStatefulFunction without name

    let mut double = RcStatefulFunction::new(move |x: &i32| x * 2);
    // Call apply to test the function
    let _result1 = double.apply(&5);

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

    let debug_str = format!("{:?}", conditional);
    assert!(debug_str.contains("RcConditionalStatefulFunction"));
    assert!(debug_str.contains("name"));
    assert!(debug_str.contains("function"));
    assert!(debug_str.contains("predicate"));

    let display_str = format!("{}", conditional);
    assert!(display_str.starts_with("RcConditionalStatefulFunction("));
    assert!(display_str.contains("RcStatefulFunction"));
    assert!(display_str.contains("RcPredicate"));
    assert!(display_str.ends_with(")"));

    // Test Debug and Display for RcConditionalStatefulFunction with name
    let mut counter2 = 0;
    let mut named_double =
        RcStatefulFunction::new_with_name("rc_stateful_double", move |x: &i32| {
            counter2 += 1;
            x * 2
        });
    // Call apply to test the function
    let _result2 = named_double.apply(&3);

    let named_conditional = named_double.when(|x: &i32| *x % 2 == 0);

    let named_debug_str = format!("{:?}", named_conditional);
    assert!(named_debug_str.contains("RcConditionalStatefulFunction"));
    assert!(named_debug_str.contains("name"));
    assert!(named_debug_str.contains("function"));
    assert!(named_debug_str.contains("predicate"));

    let named_display_str = format!("{}", named_conditional);
    assert!(named_display_str.starts_with("RcConditionalStatefulFunction("));
    assert!(named_display_str.contains("RcStatefulFunction(rc_stateful_double)"));
    assert!(named_display_str.contains("RcPredicate"));
    assert!(named_display_str.ends_with(")"));
}

// Allow unused variables in debug/display tests since they are used in closures
#[allow(unused_variables)]
#[test]
fn test_arc_conditional_stateful_function_debug_display() {
    // Test Debug and Display for ArcConditionalStatefulFunction without name

    let mut double = ArcStatefulFunction::new(move |x: &i32| x * 2);
    // Call apply to test the function
    let _result1 = double.apply(&5);

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

    let debug_str = format!("{:?}", conditional);
    assert!(debug_str.contains("ArcConditionalStatefulFunction"));
    assert!(debug_str.contains("name"));
    assert!(debug_str.contains("function"));
    assert!(debug_str.contains("predicate"));

    let display_str = format!("{}", conditional);
    assert!(display_str.starts_with("ArcConditionalStatefulFunction("));
    assert!(display_str.contains("ArcStatefulFunction"));
    assert!(display_str.contains("ArcPredicate"));
    assert!(display_str.ends_with(")"));

    // Test Debug and Display for ArcConditionalStatefulFunction with name
    let mut counter2 = 0;
    let mut named_double =
        ArcStatefulFunction::new_with_name("arc_stateful_double", move |x: &i32| {
            counter2 += 1;
            x * 2
        });
    // Call apply to test the function
    let _result2 = named_double.apply(&3);

    let named_conditional = named_double.when(|x: &i32| *x % 2 == 0);

    let named_debug_str = format!("{:?}", named_conditional);
    assert!(named_debug_str.contains("ArcConditionalStatefulFunction"));
    assert!(named_debug_str.contains("name"));
    assert!(named_debug_str.contains("function"));
    assert!(named_debug_str.contains("predicate"));

    let named_display_str = format!("{}", named_conditional);
    assert!(named_display_str.starts_with("ArcConditionalStatefulFunction("));
    assert!(named_display_str.contains("ArcStatefulFunction(arc_stateful_double)"));
    assert!(named_display_str.contains("ArcPredicate"));
    assert!(named_display_str.ends_with(")"));
}

// ============================================================================
// StatefulFunction Trait Default Methods Tests - into_once, to_once
// ============================================================================

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

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

        struct MyStatefulFunction {
            counter: Arc<AtomicUsize>,
        }

        impl StatefulFunction<i32, i32> for MyStatefulFunction {
            fn apply(&mut self, value: &i32) -> i32 {
                self.counter.fetch_add(1, Ordering::SeqCst);
                *value * 2
            }
        }

        let my_func = MyStatefulFunction {
            counter: counter.clone(),
        };

        // Test into_once() - should consume the function
        let once_func = my_func.into_once();
        let result = once_func.apply(&5);
        assert_eq!(result, 10);
        assert_eq!(counter.load(Ordering::SeqCst), 1);
    }

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

        #[derive(Clone)]
        struct MyStatefulFunction {
            counter: Arc<AtomicUsize>,
        }

        impl StatefulFunction<i32, i32> for MyStatefulFunction {
            fn apply(&mut self, value: &i32) -> i32 {
                self.counter.fetch_add(1, Ordering::SeqCst);
                *value * 2
            }
        }

        let mut my_func = MyStatefulFunction {
            counter: counter.clone(),
        };

        // Test to_once() - should not consume the original
        let once_func = my_func.to_once();
        let result = once_func.apply(&5);
        assert_eq!(result, 10);
        assert_eq!(counter.load(Ordering::SeqCst), 1);

        // Original function should still be usable
        let result2 = my_func.apply(&3);
        assert_eq!(result2, 6);
        assert_eq!(counter.load(Ordering::SeqCst), 2);
    }
}