comet-eventbus 0.1.0-pre-alpha.4

An implementation of strong-typed sync and asynchronous eventbus.
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

use crate::*;

struct Handler;

#[derive(Debug)]
struct Message {
    id: u8,
}

impl Listener<Message> for Handler {
    fn handle(&self, event: &Event<Message>) {
        println!("{:?}", event)
    }
}

#[test]
fn test() {
    let eventbus = Eventbus::new();
    let topic = TopicKey::from("foobar");
    let handler = eventbus.register(topic.clone(), Handler);
    let topic = eventbus.create_topic(topic.clone());
    let event = Event::new(topic.key.clone(), Message { id: 1 });
    topic.post(&event);
    handler.unregister();
    let event = Event::new(topic.key.clone(), Message { id: 2 });
    // this should not produce any output since we already unregister listener
    topic.post(&event);
}