roopes-core 0.1.1

Roopes is a Rust Object Oriented Pattern Element System. This crate provides generic traits and implementations for typical object-oriented patterns in Rust. It is intended to be used as a cluster of utility classes for implementing OOP-architected executables -- in Rust!
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

use crate::prelude::{
    handler::Lambda,
    publisher_subscriber::VecPublisher,
    *,
};
use std::{
    cell::RefCell,
    collections::hash_map::DefaultHasher,
    hash::Hash,
    rc::Rc,
};

#[test]
fn vec_publisher_delegate_handle()
{
    let has_run = Rc::new(RefCell::new(false));

    let mut publisher = publisher_subscriber::VecPublisher::default();

    let has_run_ext = has_run.clone();

    let heap_handler =
        handler::Heap::new(Box::new(handler::Lambda::new(move |v| {
            (*has_run_ext.borrow_mut()) = *v;
        })));

    let sub_handler: SubscribingHandler<_, _> = heap_handler.into();

    let subscriber =
        publisher_subscriber::heap::Subscriber::new(Box::new(sub_handler));

    publisher.attach(subscriber);

    let handler: HandlingPublisher<_, _> = publisher.into();

    assert!(!(*has_run.borrow()));

    handler.handle(&true);

    assert!((*has_run.borrow()));
}

#[test]
fn vec_publisher_delegate_publish()
{
    let has_run = Rc::new(RefCell::new(false));

    let mut publisher = publisher_subscriber::VecPublisher::default();

    let has_run_ext = has_run.clone();

    let heap_handler =
        handler::Heap::new(Box::new(handler::Lambda::new(move |v| {
            (*has_run_ext.borrow_mut()) = *v;
        })));

    let sub_handler: SubscribingHandler<_, _> = heap_handler.into();

    let subscriber =
        publisher_subscriber::heap::Subscriber::new(Box::new(sub_handler));

    publisher.attach(subscriber);

    let handler: HandlingPublisher<_, _> = publisher.into();

    assert!(!(*has_run.borrow()));

    handler.publish(&true);

    assert!((*has_run.borrow()));
}

#[test]
fn handling_publisher_eq()
{
    #[derive(PartialEq)]
    struct DummyPub
    {
        id: usize,
    }
    impl Publisher<()> for DummyPub
    {
        fn publish(
            &self,
            _message: &(),
        )
        {
            todo!()
        }
    }

    let dp_a1 = HandlingPublisher::from(DummyPub { id: 1 });
    let dp_b1 = HandlingPublisher::from(DummyPub { id: 2 });
    let dp_a2 = HandlingPublisher::from(DummyPub { id: 1 });

    assert!(dp_a1 == dp_a2);
    assert!(dp_a2 == dp_a1);
    assert!(dp_a1 != dp_b1);
    assert!(dp_a2 != dp_b1);
    assert!(dp_b1 != dp_a1);
    assert!(dp_b1 != dp_a2);
}

#[test]
fn format()
{
    #[derive(Debug)]
    struct DummyPub {}
    impl Publisher<()> for DummyPub
    {
        fn publish(
            &self,
            _message: &(),
        )
        {
            todo!()
        }
    }

    let hp = HandlingPublisher::from(DummyPub {});

    assert_eq!(
        format!("{:?}", hp),
        "HandlingPublisher { delegate: DummyPub }".to_string()
    );
}