Struct Reactor

pub struct Reactor {
    pub events: Arc<Mutex<HashMap<String, Waker>>>,
}

The Reactor struct stores event references for the events currently being waited on

This collection is safe to access across thread boundaries as we have wrapped with an Arc to satisfy borrowing the value across threads and it is also wrapped in a Mutex to ensure that only one thread can write to it at a time

---

Safety: We must make sure when a job is prematurely cancelled we drop any events being waited on We could do this by implementing the drop trait on the Job

Fields

events: Arc<Mutex<HashMap<String, Waker>>>

A dictionary of events where the key is a unique identifier to the event and the value contains a struct with a mechanism to resume the future

Implementations

impl Reactor

pub fn new() -> Self

Create a new reactor with an empty events register

pub async fn run(self, internal_rx: Receiver<Event>) -> Result<(), Error>

Connect to the external message broker to listen for events and react to them