chekov 0.1.1

CQRS/ES Framework
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
use super::EventNotification;
use actix::{Actor, Context, Handler};

pub struct Subscriber {
    _stream: String,
}

impl Actor for Subscriber {
    type Context = Context<Self>;
    fn started(&mut self, _ctx: &mut Self::Context) {}
}

impl Handler<EventNotification> for Subscriber {
    type Result = ();

    fn handle(&mut self, _: EventNotification, _ctx: &mut Self::Context) -> Self::Result {}
}