Struct ArcPredicate 

pub struct ArcPredicate<T> { /* private fields */ }

An Arc-based predicate with thread-safe shared ownership.

This type is suitable for scenarios where the predicate needs to be shared across threads. Composition methods borrow &self, allowing the original predicate to remain usable after composition.

Examples

use prism3_function::predicate::{Predicate, ArcPredicate};

let pred = ArcPredicate::new(|x: &i32| *x > 0);
assert!(pred.test(&5));

// Original predicate remains usable after composition
let combined = pred.and(ArcPredicate::new(|x| x % 2 == 0));
assert!(pred.test(&5));  // Still works

// Can be cloned and sent across threads
let pred_clone = pred.clone();
std::thread::spawn(move || {
    assert!(pred_clone.test(&10));
}).join().unwrap();

Author

Haixing Hu

Implementations

impl<T: 'static> ArcPredicate<T>

pub fn new<F>(f: F) -> Self

where F: Fn(&T) -> bool + Send + Sync + 'static,

Creates a new ArcPredicate from a closure.

Parameters

• f - The closure to wrap.

Returns

A new ArcPredicate instance.

Examples found in repository

examples/predicate_fn_mut_demo.rs (line 83)

fn demo_thread_safe() {
    println!("4. Thread-safe usage");

    let pred = ArcPredicate::new(|x: &i32| *x > 0);
    // clone and convert into a 'static closure so it can be moved to another thread
    let closure = pred.clone().into_fn();

    // Closure can be passed between threads
    let handle = std::thread::spawn(move || {
        let numbers = [-2, -1, 0, 1, 2, 3];
        numbers.iter().copied().filter(closure).count()
    });

    let count = handle.join().unwrap();
    println!("   Filtered result count in thread: {}", count);
    assert_eq!(count, 3);

    // Original predicate is still available
    assert!(pred.test(&5));
    println!("   ✓ ArcPredicate::to_fn() returns a thread-safe closure");
    println!("   ✓ Original predicate is still available in main thread\n");
}

examples/predicate_demo.rs (line 133)

fn arc_predicate_examples() {
    println!("--- 4. ArcPredicate Examples (Multi-threaded Scenarios) ---");

    let is_positive = ArcPredicate::new(|x: &i32| *x > 0);
    let is_even = ArcPredicate::new(|x: &i32| x % 2 == 0);

    // Create combined predicate
    let combined = is_positive.and(is_even);

    // Use in multiple threads
    let handles: Vec<_> = (0..3)
        .map(|i| {
            let pred = combined.clone();
            std::thread::spawn(move || {
                let value = i * 2;
                println!("  Thread {} testing {}: {}", i, value, pred.test(&value));
            })
        })
        .collect();

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

    // Original predicates still usable
    println!("Original predicates still available in main thread:");
    println!("  is_positive.test(&5) = {}", is_positive.test(&5));
}

/// Logical composition examples
fn logical_composition_examples() {
    println!("--- 5. Logical Composition Examples ---");

    let positive = RcPredicate::new_with_name("positive", |x: &i32| *x > 0);
    let even = RcPredicate::new_with_name("even", |x: &i32| x % 2 == 0);
    let less_than_ten = RcPredicate::new_with_name("less_than_ten", |x: &i32| *x < 10);

    // AND composition
    let positive_and_even = positive.and(even.clone());
    println!("positive AND even: name={:?}", positive_and_even.name());
    println!("  Test 4: {}", positive_and_even.test(&4));
    println!("  Test 5: {}", positive_and_even.test(&5));

    // OR composition
    let positive_or_even = positive.or(even.clone());
    println!("positive OR even: name={:?}", positive_or_even.name());
    println!("  Test -2: {}", positive_or_even.test(&-2));
    println!("  Test 5: {}", positive_or_even.test(&5));

    // NOT composition
    let not_positive = positive.not();
    println!("NOT positive: name={:?}", not_positive.name());
    println!("  Test 5: {}", not_positive.test(&5));
    println!("  Test -3: {}", not_positive.test(&-3));

    // NAND composition
    let nand = positive.nand(even.clone());
    println!("positive NAND even: name={:?}", nand.name());
    println!("  Test 3: {}", nand.test(&3)); // true NAND false = true
    println!("  Test 4: {}", nand.test(&4)); // true NAND true = false

    // XOR composition
    let xor = positive.xor(even.clone());
    println!("positive XOR even: name={:?}", xor.name());
    println!("  Test 3: {}", xor.test(&3)); // true XOR false = true
    println!("  Test 4: {}", xor.test(&4)); // true XOR true = false
    println!("  Test -2: {}", xor.test(&-2)); // false XOR true = true

    // NOR composition
    let nor = positive.nor(even.clone());
    println!("positive NOR even: name={:?}", nor.name());
    println!("  Test -3: {}", nor.test(&-3)); // false NOR false = true
    println!("  Test 3: {}", nor.test(&3)); // true NOR false = false
    println!("  Test -2: {}", nor.test(&-2)); // false NOR true = false
    println!("  Test 4: {}", nor.test(&4)); // true NOR true = false

    // Complex composition
    let complex = positive.and(even.clone()).and(less_than_ten.clone());
    println!("Complex composition: name={:?}", complex.name());
    println!("  Test 4: {}", complex.test(&4));
    println!("  Test 12: {}", complex.test(&12));
}

/// Interior mutability examples
fn interior_mutability_examples() {
    println!("--- 6. Interior Mutability Examples ---");

    // BoxPredicate with counter (RefCell)
    println!("BoxPredicate with counter:");
    let count = RefCell::new(0);
    let pred = BoxPredicate::new(move |x: &i32| {
        *count.borrow_mut() += 1;
        *x > 0
    });
    println!("  Test 5: {}", pred.test(&5));
    println!("  Test -3: {}", pred.test(&-3));
    println!("  Test 10: {}", pred.test(&10));
    // Note: count is moved into the closure, so we can't access it here

    // RcPredicate with cache (RefCell + HashMap)
    println!("\nRcPredicate with cache:");
    let cache: RefCell<HashMap<i32, bool>> = RefCell::new(HashMap::new());
    let expensive_pred = RcPredicate::new(move |x: &i32| {
        let mut c = cache.borrow_mut();
        *c.entry(*x).or_insert_with(|| {
            println!("    Computing result for {} (expensive operation)", x);
            *x > 0 && x % 2 == 0
        })
    });

    println!("  First test 4:");
    println!("    Result: {}", expensive_pred.test(&4));
    println!("  Test 4 again (using cache):");
    println!("    Result: {}", expensive_pred.test(&4));
    println!("  Test 3:");
    println!("    Result: {}", expensive_pred.test(&3));

    // ArcPredicate with thread-safe counter (Mutex)
    println!("\nArcPredicate with thread-safe counter:");
    let counter = Arc::new(Mutex::new(0));
    let pred = ArcPredicate::new({
        let counter = Arc::clone(&counter);
        move |x: &i32| {
            let mut c = counter.lock().unwrap();
            *c += 1;
            *x > 0
        }
    });

    let pred_clone = pred.clone();
    let counter_clone = Arc::clone(&counter);

    let handle = std::thread::spawn(move || {
        pred_clone.test(&5);
        pred_clone.test(&10);
    });

    pred.test(&3);
    handle.join().unwrap();

    println!("  Total call count: {}", counter_clone.lock().unwrap());
}

examples/predicate_set_name_demo.rs (line 87)

fn demo_arc_predicate() {
    println!("3. ArcPredicate Naming Functionality (Thread-Safe)");

    // Using new_with_name
    let pred1 = ArcPredicate::new_with_name("is_uppercase", |s: &String| {
        s.chars().all(|c| c.is_uppercase() || !c.is_alphabetic())
    });
    println!("   Using new_with_name:");
    println!("     Name: {:?}", pred1.name());
    println!("     Test 'HELLO': {}", pred1.test(&"HELLO".to_string()));

    // Using set_name
    let mut pred2 = ArcPredicate::new(|s: &String| s.len() > 5);
    println!("\n   Using set_name:");
    println!("     Initial name: {:?}", pred2.name());
    pred2.set_name("longer_than_5");
    println!("     Name after setting: {:?}", pred2.name());
    println!(
        "     Test 'Hello World': {}",
        pred2.test(&"Hello World".to_string())
    );

    // Name is preserved when sharing between threads
    let pred3 = pred2.clone();
    let handle = std::thread::spawn(move || {
        let name = pred3.name().map(|s| s.to_string());
        let result = pred3.test(&"Threading".to_string());
        (name, result)
    });

    let (name, result) = handle.join().unwrap();
    println!("\n   Accessing from thread:");
    println!("     Name in thread: {:?}", name);
    println!("     Test 'Threading' in thread: {}", result);

    // Original predicate is still available
    println!("\n   Original predicate still available:");
    println!("     Original name: {:?}", pred2.name());
    println!("     Test 'Rust': {}\n", pred2.test(&"Rust".to_string()));
}

pub fn new_with_name<F>(name: &str, f: F) -> Self

where F: Fn(&T) -> bool + Send + Sync + 'static,

Creates a named ArcPredicate from a closure.

Parameters

• name - The name for this predicate.
• f - The closure to wrap.

Returns

A new named ArcPredicate instance.

Examples found in repository

examples/predicate_set_name_demo.rs (lines 79-81)

fn demo_arc_predicate() {
    println!("3. ArcPredicate Naming Functionality (Thread-Safe)");

    // Using new_with_name
    let pred1 = ArcPredicate::new_with_name("is_uppercase", |s: &String| {
        s.chars().all(|c| c.is_uppercase() || !c.is_alphabetic())
    });
    println!("   Using new_with_name:");
    println!("     Name: {:?}", pred1.name());
    println!("     Test 'HELLO': {}", pred1.test(&"HELLO".to_string()));

    // Using set_name
    let mut pred2 = ArcPredicate::new(|s: &String| s.len() > 5);
    println!("\n   Using set_name:");
    println!("     Initial name: {:?}", pred2.name());
    pred2.set_name("longer_than_5");
    println!("     Name after setting: {:?}", pred2.name());
    println!(
        "     Test 'Hello World': {}",
        pred2.test(&"Hello World".to_string())
    );

    // Name is preserved when sharing between threads
    let pred3 = pred2.clone();
    let handle = std::thread::spawn(move || {
        let name = pred3.name().map(|s| s.to_string());
        let result = pred3.test(&"Threading".to_string());
        (name, result)
    });

    let (name, result) = handle.join().unwrap();
    println!("\n   Accessing from thread:");
    println!("     Name in thread: {:?}", name);
    println!("     Test 'Threading' in thread: {}", result);

    // Original predicate is still available
    println!("\n   Original predicate still available:");
    println!("     Original name: {:?}", pred2.name());
    println!("     Test 'Rust': {}\n", pred2.test(&"Rust".to_string()));
}

pub fn always_true() -> Self

Creates a predicate that always returns true.

Returns

A new ArcPredicate that always returns true.

Examples

use prism3_function::predicate::{Predicate, ArcPredicate};

let pred: ArcPredicate<i32> = ArcPredicate::always_true();
assert!(pred.test(&42));
assert!(pred.test(&-1));
assert!(pred.test(&0));

Examples found in repository

examples/always_predicate_demo.rs (line 73)

fn main() {
    println!("=== BoxPredicate always_true/always_false Demo ===\n");

    // BoxPredicate::always_true
    let always_true: BoxPredicate<i32> = BoxPredicate::always_true();
    println!("BoxPredicate::always_true():");
    println!("  test(&42): {}", always_true.test(&42));
    println!("  test(&-1): {}", always_true.test(&-1));
    println!("  test(&0): {}", always_true.test(&0));
    println!("  name: {:?}", always_true.name());

    // BoxPredicate::always_false
    let always_false: BoxPredicate<i32> = BoxPredicate::always_false();
    println!("\nBoxPredicate::always_false():");
    println!("  test(&42): {}", always_false.test(&42));
    println!("  test(&-1): {}", always_false.test(&-1));
    println!("  test(&0): {}", always_false.test(&0));
    println!("  name: {:?}", always_false.name());

    println!("\n=== RcPredicate always_true/always_false Demo ===\n");

    // RcPredicate::always_true
    let rc_always_true: RcPredicate<String> = RcPredicate::always_true();
    println!("RcPredicate::always_true():");
    println!(
        "  test(&\"hello\"): {}",
        rc_always_true.test(&"hello".to_string())
    );
    println!(
        "  test(&\"world\"): {}",
        rc_always_true.test(&"world".to_string())
    );
    println!("  name: {:?}", rc_always_true.name());

    // RcPredicate::always_false
    let rc_always_false: RcPredicate<String> = RcPredicate::always_false();
    println!("\nRcPredicate::always_false():");
    println!(
        "  test(&\"hello\"): {}",
        rc_always_false.test(&"hello".to_string())
    );
    println!(
        "  test(&\"world\"): {}",
        rc_always_false.test(&"world".to_string())
    );
    println!("  name: {:?}", rc_always_false.name());

    // Can be cloned and reused
    let rc_clone = rc_always_true.clone();
    println!("\nAfter cloning, still usable:");
    println!(
        "  Original: test(&\"test\"): {}",
        rc_always_true.test(&"test".to_string())
    );
    println!(
        "  Clone: test(&\"test\"): {}",
        rc_clone.test(&"test".to_string())
    );

    println!("\n=== ArcPredicate always_true/always_false Demo ===\n");

    // ArcPredicate::always_true
    let arc_always_true: ArcPredicate<i32> = ArcPredicate::always_true();
    println!("ArcPredicate::always_true():");
    println!("  test(&100): {}", arc_always_true.test(&100));
    println!("  test(&-100): {}", arc_always_true.test(&-100));
    println!("  name: {:?}", arc_always_true.name());

    // ArcPredicate::always_false
    let arc_always_false: ArcPredicate<i32> = ArcPredicate::always_false();
    println!("\nArcPredicate::always_false():");
    println!("  test(&100): {}", arc_always_false.test(&100));
    println!("  test(&-100): {}", arc_always_false.test(&-100));
    println!("  name: {:?}", arc_always_false.name());

    println!("\n=== Combining with other predicates ===\n");

    // Combining with always_true (AND)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_and_true = is_positive.and(BoxPredicate::always_true());
    println!("is_positive AND always_true:");
    println!(
        "  test(&5): {} (equivalent to is_positive)",
        combined_and_true.test(&5)
    );
    println!(
        "  test(&-3): {} (equivalent to is_positive)",
        combined_and_true.test(&-3)
    );

    // Combining with always_false (AND)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_and_false = is_positive.and(BoxPredicate::always_false());
    println!("\nis_positive AND always_false:");
    println!("  test(&5): {} (always false)", combined_and_false.test(&5));
    println!(
        "  test(&-3): {} (always false)",
        combined_and_false.test(&-3)
    );

    // Combining with always_true (OR)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_or_true = is_positive.or(BoxPredicate::always_true());
    println!("\nis_positive OR always_true:");
    println!("  test(&5): {} (always true)", combined_or_true.test(&5));
    println!("  test(&-3): {} (always true)", combined_or_true.test(&-3));

    // Combining with always_false (OR)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_or_false = is_positive.or(BoxPredicate::always_false());
    println!("\nis_positive OR always_false:");
    println!(
        "  test(&5): {} (equivalent to is_positive)",
        combined_or_false.test(&5)
    );
    println!(
        "  test(&-3): {} (equivalent to is_positive)",
        combined_or_false.test(&-3)
    );

    println!("\n=== Practical scenarios: Default pass/reject filters ===\n");

    // Scenario 1: Default pass-all filter
    let numbers = vec![1, 2, 3, 4, 5];
    let pass_all = BoxPredicate::<i32>::always_true();
    let filtered: Vec<_> = numbers.iter().copied().filter(pass_all.into_fn()).collect();
    println!("Default pass all elements: {:?} -> {:?}", numbers, filtered);

    // Scenario 2: Default reject-all filter
    let numbers = vec![1, 2, 3, 4, 5];
    let reject_all = BoxPredicate::<i32>::always_false();
    let filtered: Vec<_> = numbers
        .iter()
        .copied()
        .filter(reject_all.into_fn())
        .collect();
    println!(
        "Default reject all elements: {:?} -> {:?}",
        numbers, filtered
    );

    // Scenario 3: Configurable filter
    fn configurable_filter(enable_filter: bool) -> BoxPredicate<i32> {
        if enable_filter {
            BoxPredicate::new(|x: &i32| *x > 3)
        } else {
            BoxPredicate::always_true()
        }
    }

    let numbers = vec![1, 2, 3, 4, 5];

    let filter_enabled = configurable_filter(true);
    let filtered: Vec<_> = numbers
        .iter()
        .copied()
        .filter(filter_enabled.into_fn())
        .collect();
    println!("\nFilter enabled: {:?} -> {:?}", numbers, filtered);

    let filter_disabled = configurable_filter(false);
    let filtered: Vec<_> = numbers
        .iter()
        .copied()
        .filter(filter_disabled.into_fn())
        .collect();
    println!("Filter disabled: {:?} -> {:?}", numbers, filtered);
}

pub fn always_false() -> Self

Creates a predicate that always returns false.

Returns

A new ArcPredicate that always returns false.

Examples

use prism3_function::predicate::{Predicate, ArcPredicate};

let pred: ArcPredicate<i32> = ArcPredicate::always_false();
assert!(!pred.test(&42));
assert!(!pred.test(&-1));
assert!(!pred.test(&0));

Examples found in repository

examples/always_predicate_demo.rs (line 80)

fn main() {
    println!("=== BoxPredicate always_true/always_false Demo ===\n");

    // BoxPredicate::always_true
    let always_true: BoxPredicate<i32> = BoxPredicate::always_true();
    println!("BoxPredicate::always_true():");
    println!("  test(&42): {}", always_true.test(&42));
    println!("  test(&-1): {}", always_true.test(&-1));
    println!("  test(&0): {}", always_true.test(&0));
    println!("  name: {:?}", always_true.name());

    // BoxPredicate::always_false
    let always_false: BoxPredicate<i32> = BoxPredicate::always_false();
    println!("\nBoxPredicate::always_false():");
    println!("  test(&42): {}", always_false.test(&42));
    println!("  test(&-1): {}", always_false.test(&-1));
    println!("  test(&0): {}", always_false.test(&0));
    println!("  name: {:?}", always_false.name());

    println!("\n=== RcPredicate always_true/always_false Demo ===\n");

    // RcPredicate::always_true
    let rc_always_true: RcPredicate<String> = RcPredicate::always_true();
    println!("RcPredicate::always_true():");
    println!(
        "  test(&\"hello\"): {}",
        rc_always_true.test(&"hello".to_string())
    );
    println!(
        "  test(&\"world\"): {}",
        rc_always_true.test(&"world".to_string())
    );
    println!("  name: {:?}", rc_always_true.name());

    // RcPredicate::always_false
    let rc_always_false: RcPredicate<String> = RcPredicate::always_false();
    println!("\nRcPredicate::always_false():");
    println!(
        "  test(&\"hello\"): {}",
        rc_always_false.test(&"hello".to_string())
    );
    println!(
        "  test(&\"world\"): {}",
        rc_always_false.test(&"world".to_string())
    );
    println!("  name: {:?}", rc_always_false.name());

    // Can be cloned and reused
    let rc_clone = rc_always_true.clone();
    println!("\nAfter cloning, still usable:");
    println!(
        "  Original: test(&\"test\"): {}",
        rc_always_true.test(&"test".to_string())
    );
    println!(
        "  Clone: test(&\"test\"): {}",
        rc_clone.test(&"test".to_string())
    );

    println!("\n=== ArcPredicate always_true/always_false Demo ===\n");

    // ArcPredicate::always_true
    let arc_always_true: ArcPredicate<i32> = ArcPredicate::always_true();
    println!("ArcPredicate::always_true():");
    println!("  test(&100): {}", arc_always_true.test(&100));
    println!("  test(&-100): {}", arc_always_true.test(&-100));
    println!("  name: {:?}", arc_always_true.name());

    // ArcPredicate::always_false
    let arc_always_false: ArcPredicate<i32> = ArcPredicate::always_false();
    println!("\nArcPredicate::always_false():");
    println!("  test(&100): {}", arc_always_false.test(&100));
    println!("  test(&-100): {}", arc_always_false.test(&-100));
    println!("  name: {:?}", arc_always_false.name());

    println!("\n=== Combining with other predicates ===\n");

    // Combining with always_true (AND)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_and_true = is_positive.and(BoxPredicate::always_true());
    println!("is_positive AND always_true:");
    println!(
        "  test(&5): {} (equivalent to is_positive)",
        combined_and_true.test(&5)
    );
    println!(
        "  test(&-3): {} (equivalent to is_positive)",
        combined_and_true.test(&-3)
    );

    // Combining with always_false (AND)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_and_false = is_positive.and(BoxPredicate::always_false());
    println!("\nis_positive AND always_false:");
    println!("  test(&5): {} (always false)", combined_and_false.test(&5));
    println!(
        "  test(&-3): {} (always false)",
        combined_and_false.test(&-3)
    );

    // Combining with always_true (OR)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_or_true = is_positive.or(BoxPredicate::always_true());
    println!("\nis_positive OR always_true:");
    println!("  test(&5): {} (always true)", combined_or_true.test(&5));
    println!("  test(&-3): {} (always true)", combined_or_true.test(&-3));

    // Combining with always_false (OR)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_or_false = is_positive.or(BoxPredicate::always_false());
    println!("\nis_positive OR always_false:");
    println!(
        "  test(&5): {} (equivalent to is_positive)",
        combined_or_false.test(&5)
    );
    println!(
        "  test(&-3): {} (equivalent to is_positive)",
        combined_or_false.test(&-3)
    );

    println!("\n=== Practical scenarios: Default pass/reject filters ===\n");

    // Scenario 1: Default pass-all filter
    let numbers = vec![1, 2, 3, 4, 5];
    let pass_all = BoxPredicate::<i32>::always_true();
    let filtered: Vec<_> = numbers.iter().copied().filter(pass_all.into_fn()).collect();
    println!("Default pass all elements: {:?} -> {:?}", numbers, filtered);

    // Scenario 2: Default reject-all filter
    let numbers = vec![1, 2, 3, 4, 5];
    let reject_all = BoxPredicate::<i32>::always_false();
    let filtered: Vec<_> = numbers
        .iter()
        .copied()
        .filter(reject_all.into_fn())
        .collect();
    println!(
        "Default reject all elements: {:?} -> {:?}",
        numbers, filtered
    );

    // Scenario 3: Configurable filter
    fn configurable_filter(enable_filter: bool) -> BoxPredicate<i32> {
        if enable_filter {
            BoxPredicate::new(|x: &i32| *x > 3)
        } else {
            BoxPredicate::always_true()
        }
    }

    let numbers = vec![1, 2, 3, 4, 5];

    let filter_enabled = configurable_filter(true);
    let filtered: Vec<_> = numbers
        .iter()
        .copied()
        .filter(filter_enabled.into_fn())
        .collect();
    println!("\nFilter enabled: {:?} -> {:?}", numbers, filtered);

    let filter_disabled = configurable_filter(false);
    let filtered: Vec<_> = numbers
        .iter()
        .copied()
        .filter(filter_disabled.into_fn())
        .collect();
    println!("Filter disabled: {:?} -> {:?}", numbers, filtered);
}

pub fn name(&self) -> Option<&str>

Returns the name of this predicate, if set.

Returns

An Option containing the predicate’s name.

Examples found in repository

examples/predicate_set_name_demo.rs (line 83)

fn demo_arc_predicate() {
    println!("3. ArcPredicate Naming Functionality (Thread-Safe)");

    // Using new_with_name
    let pred1 = ArcPredicate::new_with_name("is_uppercase", |s: &String| {
        s.chars().all(|c| c.is_uppercase() || !c.is_alphabetic())
    });
    println!("   Using new_with_name:");
    println!("     Name: {:?}", pred1.name());
    println!("     Test 'HELLO': {}", pred1.test(&"HELLO".to_string()));

    // Using set_name
    let mut pred2 = ArcPredicate::new(|s: &String| s.len() > 5);
    println!("\n   Using set_name:");
    println!("     Initial name: {:?}", pred2.name());
    pred2.set_name("longer_than_5");
    println!("     Name after setting: {:?}", pred2.name());
    println!(
        "     Test 'Hello World': {}",
        pred2.test(&"Hello World".to_string())
    );

    // Name is preserved when sharing between threads
    let pred3 = pred2.clone();
    let handle = std::thread::spawn(move || {
        let name = pred3.name().map(|s| s.to_string());
        let result = pred3.test(&"Threading".to_string());
        (name, result)
    });

    let (name, result) = handle.join().unwrap();
    println!("\n   Accessing from thread:");
    println!("     Name in thread: {:?}", name);
    println!("     Test 'Threading' in thread: {}", result);

    // Original predicate is still available
    println!("\n   Original predicate still available:");
    println!("     Original name: {:?}", pred2.name());
    println!("     Test 'Rust': {}\n", pred2.test(&"Rust".to_string()));
}

examples/always_predicate_demo.rs (line 77)

fn main() {
    println!("=== BoxPredicate always_true/always_false Demo ===\n");

    // BoxPredicate::always_true
    let always_true: BoxPredicate<i32> = BoxPredicate::always_true();
    println!("BoxPredicate::always_true():");
    println!("  test(&42): {}", always_true.test(&42));
    println!("  test(&-1): {}", always_true.test(&-1));
    println!("  test(&0): {}", always_true.test(&0));
    println!("  name: {:?}", always_true.name());

    // BoxPredicate::always_false
    let always_false: BoxPredicate<i32> = BoxPredicate::always_false();
    println!("\nBoxPredicate::always_false():");
    println!("  test(&42): {}", always_false.test(&42));
    println!("  test(&-1): {}", always_false.test(&-1));
    println!("  test(&0): {}", always_false.test(&0));
    println!("  name: {:?}", always_false.name());

    println!("\n=== RcPredicate always_true/always_false Demo ===\n");

    // RcPredicate::always_true
    let rc_always_true: RcPredicate<String> = RcPredicate::always_true();
    println!("RcPredicate::always_true():");
    println!(
        "  test(&\"hello\"): {}",
        rc_always_true.test(&"hello".to_string())
    );
    println!(
        "  test(&\"world\"): {}",
        rc_always_true.test(&"world".to_string())
    );
    println!("  name: {:?}", rc_always_true.name());

    // RcPredicate::always_false
    let rc_always_false: RcPredicate<String> = RcPredicate::always_false();
    println!("\nRcPredicate::always_false():");
    println!(
        "  test(&\"hello\"): {}",
        rc_always_false.test(&"hello".to_string())
    );
    println!(
        "  test(&\"world\"): {}",
        rc_always_false.test(&"world".to_string())
    );
    println!("  name: {:?}", rc_always_false.name());

    // Can be cloned and reused
    let rc_clone = rc_always_true.clone();
    println!("\nAfter cloning, still usable:");
    println!(
        "  Original: test(&\"test\"): {}",
        rc_always_true.test(&"test".to_string())
    );
    println!(
        "  Clone: test(&\"test\"): {}",
        rc_clone.test(&"test".to_string())
    );

    println!("\n=== ArcPredicate always_true/always_false Demo ===\n");

    // ArcPredicate::always_true
    let arc_always_true: ArcPredicate<i32> = ArcPredicate::always_true();
    println!("ArcPredicate::always_true():");
    println!("  test(&100): {}", arc_always_true.test(&100));
    println!("  test(&-100): {}", arc_always_true.test(&-100));
    println!("  name: {:?}", arc_always_true.name());

    // ArcPredicate::always_false
    let arc_always_false: ArcPredicate<i32> = ArcPredicate::always_false();
    println!("\nArcPredicate::always_false():");
    println!("  test(&100): {}", arc_always_false.test(&100));
    println!("  test(&-100): {}", arc_always_false.test(&-100));
    println!("  name: {:?}", arc_always_false.name());

    println!("\n=== Combining with other predicates ===\n");

    // Combining with always_true (AND)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_and_true = is_positive.and(BoxPredicate::always_true());
    println!("is_positive AND always_true:");
    println!(
        "  test(&5): {} (equivalent to is_positive)",
        combined_and_true.test(&5)
    );
    println!(
        "  test(&-3): {} (equivalent to is_positive)",
        combined_and_true.test(&-3)
    );

    // Combining with always_false (AND)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_and_false = is_positive.and(BoxPredicate::always_false());
    println!("\nis_positive AND always_false:");
    println!("  test(&5): {} (always false)", combined_and_false.test(&5));
    println!(
        "  test(&-3): {} (always false)",
        combined_and_false.test(&-3)
    );

    // Combining with always_true (OR)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_or_true = is_positive.or(BoxPredicate::always_true());
    println!("\nis_positive OR always_true:");
    println!("  test(&5): {} (always true)", combined_or_true.test(&5));
    println!("  test(&-3): {} (always true)", combined_or_true.test(&-3));

    // Combining with always_false (OR)
    let is_positive = BoxPredicate::new(|x: &i32| *x > 0);
    let combined_or_false = is_positive.or(BoxPredicate::always_false());
    println!("\nis_positive OR always_false:");
    println!(
        "  test(&5): {} (equivalent to is_positive)",
        combined_or_false.test(&5)
    );
    println!(
        "  test(&-3): {} (equivalent to is_positive)",
        combined_or_false.test(&-3)
    );

    println!("\n=== Practical scenarios: Default pass/reject filters ===\n");

    // Scenario 1: Default pass-all filter
    let numbers = vec![1, 2, 3, 4, 5];
    let pass_all = BoxPredicate::<i32>::always_true();
    let filtered: Vec<_> = numbers.iter().copied().filter(pass_all.into_fn()).collect();
    println!("Default pass all elements: {:?} -> {:?}", numbers, filtered);

    // Scenario 2: Default reject-all filter
    let numbers = vec![1, 2, 3, 4, 5];
    let reject_all = BoxPredicate::<i32>::always_false();
    let filtered: Vec<_> = numbers
        .iter()
        .copied()
        .filter(reject_all.into_fn())
        .collect();
    println!(
        "Default reject all elements: {:?} -> {:?}",
        numbers, filtered
    );

    // Scenario 3: Configurable filter
    fn configurable_filter(enable_filter: bool) -> BoxPredicate<i32> {
        if enable_filter {
            BoxPredicate::new(|x: &i32| *x > 3)
        } else {
            BoxPredicate::always_true()
        }
    }

    let numbers = vec![1, 2, 3, 4, 5];

    let filter_enabled = configurable_filter(true);
    let filtered: Vec<_> = numbers
        .iter()
        .copied()
        .filter(filter_enabled.into_fn())
        .collect();
    println!("\nFilter enabled: {:?} -> {:?}", numbers, filtered);

    let filter_disabled = configurable_filter(false);
    let filtered: Vec<_> = numbers
        .iter()
        .copied()
        .filter(filter_disabled.into_fn())
        .collect();
    println!("Filter disabled: {:?} -> {:?}", numbers, filtered);
}

pub fn set_name(&mut self, name: &str)

Sets the name of this predicate.

Parameters

• name - The new name for this predicate.

Examples found in repository

examples/predicate_set_name_demo.rs (line 90)

fn demo_arc_predicate() {
    println!("3. ArcPredicate Naming Functionality (Thread-Safe)");

    // Using new_with_name
    let pred1 = ArcPredicate::new_with_name("is_uppercase", |s: &String| {
        s.chars().all(|c| c.is_uppercase() || !c.is_alphabetic())
    });
    println!("   Using new_with_name:");
    println!("     Name: {:?}", pred1.name());
    println!("     Test 'HELLO': {}", pred1.test(&"HELLO".to_string()));

    // Using set_name
    let mut pred2 = ArcPredicate::new(|s: &String| s.len() > 5);
    println!("\n   Using set_name:");
    println!("     Initial name: {:?}", pred2.name());
    pred2.set_name("longer_than_5");
    println!("     Name after setting: {:?}", pred2.name());
    println!(
        "     Test 'Hello World': {}",
        pred2.test(&"Hello World".to_string())
    );

    // Name is preserved when sharing between threads
    let pred3 = pred2.clone();
    let handle = std::thread::spawn(move || {
        let name = pred3.name().map(|s| s.to_string());
        let result = pred3.test(&"Threading".to_string());
        (name, result)
    });

    let (name, result) = handle.join().unwrap();
    println!("\n   Accessing from thread:");
    println!("     Name in thread: {:?}", name);
    println!("     Test 'Threading' in thread: {}", result);

    // Original predicate is still available
    println!("\n   Original predicate still available:");
    println!("     Original name: {:?}", pred2.name());
    println!("     Test 'Rust': {}\n", pred2.test(&"Rust".to_string()));
}

pub fn and<P>(&self, other: P) -> ArcPredicate<T>

where T: Send + Sync, P: Predicate<T> + Send + Sync + 'static,

Returns a predicate that represents the logical AND of this predicate and another.

Parameters

• other - The other predicate to combine with. Note: This parameter is passed by value and will transfer ownership. If you need to preserve the original predicate, clone it first (if it implements Clone). Can be:
  • A closure: |x: &T| -> bool
  • A function pointer: fn(&T) -> bool
  • A BoxPredicate<T>
  • An RcPredicate<T>
  • Another ArcPredicate<T> (will be moved)
  • Any type implementing Predicate<T> + Send + Sync

Returns

A new ArcPredicate representing the logical AND.

Examples

use prism3_function::predicate::{Predicate, ArcPredicate};
use std::thread;

let is_positive = ArcPredicate::new(|x: &i32| *x > 0);
let is_even = |x: &i32| x % 2 == 0;

let combined = is_positive.and(is_even);

// can be used across threads
let handle = thread::spawn(move || {
    combined.test(&4)
});

assert!(handle.join().unwrap());
assert!(is_positive.test(&5)); // original predicate still usable

Examples found in repository

examples/predicate_demo.rs (line 137)

fn arc_predicate_examples() {
    println!("--- 4. ArcPredicate Examples (Multi-threaded Scenarios) ---");

    let is_positive = ArcPredicate::new(|x: &i32| *x > 0);
    let is_even = ArcPredicate::new(|x: &i32| x % 2 == 0);

    // Create combined predicate
    let combined = is_positive.and(is_even);

    // Use in multiple threads
    let handles: Vec<_> = (0..3)
        .map(|i| {
            let pred = combined.clone();
            std::thread::spawn(move || {
                let value = i * 2;
                println!("  Thread {} testing {}: {}", i, value, pred.test(&value));
            })
        })
        .collect();

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

    // Original predicates still usable
    println!("Original predicates still available in main thread:");
    println!("  is_positive.test(&5) = {}", is_positive.test(&5));
}

pub fn or<P>(&self, other: P) -> ArcPredicate<T>

where T: Send + Sync, P: Predicate<T> + Send + Sync + 'static,

Returns a predicate that represents the logical OR of this predicate and another.

Parameters

• other - The other predicate to combine with. Note: This parameter is passed by value and will transfer ownership. If you need to preserve the original predicate, clone it first (if it implements Clone). Can be:
  • A closure: |x: &T| -> bool
  • A function pointer: fn(&T) -> bool
  • A BoxPredicate<T>
  • An RcPredicate<T>
  • Another ArcPredicate<T> (will be moved)
  • Any type implementing Predicate<T> + Send + Sync

Returns

A new ArcPredicate representing the logical OR. Thread-safe.

Examples

use prism3_function::predicate::{Predicate, ArcPredicate};

let is_negative = ArcPredicate::new(|x: &i32| *x < 0);
let is_large = |x: &i32| *x > 100;

let combined = is_negative.or(is_large);
assert!(combined.test(&-5));
assert!(combined.test(&150));
assert!(is_negative.test(&-10)); // original predicate still usable

pub fn not(&self) -> ArcPredicate<T>

where T: Send + Sync,

Returns a predicate that represents the logical negation of this predicate.

Returns

A new ArcPredicate representing the logical negation.

pub fn nand<P>(&self, other: P) -> ArcPredicate<T>

where T: Send + Sync, P: Predicate<T> + Send + Sync + 'static,

Returns a predicate that represents the logical NAND (NOT AND) of this predicate and another.

NAND returns true unless both predicates are true. Equivalent to !(self AND other).

Parameters

• other - The other predicate to combine with. Note: This parameter is passed by value and will transfer ownership. If you need to preserve the original predicate, clone it first (if it implements Clone). Accepts closures, function pointers, or any Predicate<T> + Send + Sync implementation.

Returns

A new ArcPredicate representing the logical NAND. Thread-safe.

Examples

use prism3_function::predicate::{Predicate, ArcPredicate};

let is_positive = ArcPredicate::new(|x: &i32| *x > 0);
let is_even = |x: &i32| x % 2 == 0;

let nand = is_positive.nand(is_even);
assert!(nand.test(&3));   // !(true && false) = true
assert!(!nand.test(&4));  // !(true && true) = false

pub fn xor<P>(&self, other: P) -> ArcPredicate<T>

where T: Send + Sync, P: Predicate<T> + Send + Sync + 'static,

Returns a predicate that represents the logical XOR (exclusive OR) of this predicate and another.

XOR returns true if exactly one of the predicates is true.

Parameters

• other - The other predicate to combine with. Note: This parameter is passed by value and will transfer ownership. If you need to preserve the original predicate, clone it first (if it implements Clone).

Returns

A new ArcPredicate representing the logical XOR.

pub fn nor<P>(&self, other: P) -> ArcPredicate<T>

where T: Send + Sync, P: Predicate<T> + Send + Sync + 'static,

Returns a predicate that represents the logical NOR (NOT OR) of this predicate and another.

NOR returns true only when both predicates are false. Equivalent to !(self OR other).

Parameters

• other - The other predicate to combine with. Note: This parameter is passed by value and will transfer ownership. If you need to preserve the original predicate, clone it first (if it implements Clone). Accepts closures, function pointers, or any Predicate<T> + Send + Sync implementation.

Returns

A new ArcPredicate representing the logical NOR. Thread-safe.

Examples

use prism3_function::predicate::{Predicate, ArcPredicate};

let is_positive = ArcPredicate::new(|x: &i32| *x > 0);
let is_even = |x: &i32| x % 2 == 0;

let nor = is_positive.nor(is_even);
assert!(nor.test(&-3));   // !(false || false) = true
assert!(!nor.test(&4));   // !(true || true) = false
assert!(!nor.test(&3));   // !(true || false) = false

Trait Implementations

impl<T> Clone for ArcPredicate<T>

fn clone(&self) -> Self

Clones this predicate.

Creates a new instance that shares the underlying function with the original, allowing multiple references to the same predicate logic.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for ArcPredicate<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Implements Debug trait for ArcPredicate

Shows the predicate name in debug struct format.

impl<T> Display for ArcPredicate<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Implements Display trait for ArcPredicate

Shows the predicate name if available, or “unnamed” as default.

impl<T: 'static> Predicate<T> for ArcPredicate<T>

fn test(&self, value: &T) -> bool

Tests whether the given value satisfies this predicate.

fn into_box(self) -> BoxPredicate<T>

Converts this predicate into a BoxPredicate.

fn into_rc(self) -> RcPredicate<T>

Converts this predicate into an RcPredicate.

fn into_arc(self) -> ArcPredicate<T>

where T: Send + Sync,

Converts this predicate into an ArcPredicate.

fn into_fn(self) -> impl Fn(&T) -> bool

Converts this predicate into a closure that can be used directly with standard library methods.

fn to_box(&self) -> BoxPredicate<T>

Converts a reference to this predicate into a BoxPredicate.

fn to_rc(&self) -> RcPredicate<T>

Converts a reference to this predicate into an RcPredicate.

fn to_arc(&self) -> ArcPredicate<T>

Converts a reference to this predicate into an ArcPredicate.

fn to_fn(&self) -> impl Fn(&T) -> bool

Converts a reference to this predicate into a closure that can be used directly with standard library methods.