event_store/subscriptions/
subscriber.rs

1use crate::prelude::RecordedEvents;
2use actix::prelude::*;
3
4#[derive(Debug)]
5pub struct Subscriber {
6    pub recipient: Recipient<RecordedEvents>,
7}
8
9impl Actor for Subscriber {
10    type Context = Context<Self>;
11}