agave-event-system 0.2.0

A local pub-sub system used by agave validators to publish events to outside processes.
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

use crate::{Event, backend, publisher::Publisher};

/// A handle to a typed [`Event`] stream that can create publishers
/// on demand.
pub struct PublisherFactory<E: Event> {
    backend: backend::PublisherFactory<E>,
}

impl<E: Event> PublisherFactory<E> {
    pub fn try_create_publisher(&self) -> Option<Publisher<E>> {
        self.backend.try_create_publisher().map(Publisher::new)
    }

    pub(crate) fn new(backend: backend::PublisherFactory<E>) -> Self {
        Self { backend }
    }
}

impl<E: Event> Clone for PublisherFactory<E> {
    fn clone(&self) -> Self {
        Self {
            backend: self.backend.clone(),
        }
    }
}

impl<E: Event> std::fmt::Debug for PublisherFactory<E> {
    fn fmt(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        self.backend.fmt(formatter)
    }
}