made-core 0.8.0

Domain core of MADE: entities, value objects, events, ports. No IO.
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

use async_trait::async_trait;

use crate::ports::{CeremonyEventSubscriberPort, PositionedRecord};

/// The subscriber a stream gets when nothing is projecting from it.
///
/// Its own type rather than an `Option`, for the reason
/// [`NoopMetricsRecorder`](super::NoopMetricsRecorder) is one: the
/// append path notifies unconditionally, so there is no branch to get
/// wrong and no configuration in which the notification is skipped.
#[derive(Clone, Copy, Debug, Default)]
pub struct NoopCeremonyEventSubscriber;

#[async_trait]
impl CeremonyEventSubscriberPort for NoopCeremonyEventSubscriber {
    async fn observe(&self, _records: &[PositionedRecord]) {}
}

#[cfg(test)]
mod tests {
    use super::*;

    #[tokio::test]
    async fn observes_nothing_and_says_nothing() {
        NoopCeremonyEventSubscriber.observe(&[]).await;
    }
}