bevy_event_bus 1.1.2

A Bevy plugin that connects Bevy's event system to external message brokers like Kafka
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
32
33
34
35
36
37
38
39
40

use bevy::prelude::*;
use std::sync::{Arc, RwLock};

use super::event_bus_backend::EventBusBackend;
use crate::runtime;

/// Resource wrapper for EventBusBackend
#[derive(Resource, Clone)]
pub struct EventBusBackendResource(pub Arc<RwLock<Box<dyn EventBusBackend>>>);

impl EventBusBackendResource {
    pub fn new<B: EventBusBackend>(backend: B) -> Self {
        Self(Arc::new(RwLock::new(Box::new(backend))))
    }
    pub fn from_box(boxed: Box<dyn EventBusBackend>) -> Self {
        Self(Arc::new(RwLock::new(boxed)))
    }
}

// Provide explicit helpers instead of Deref for clarity
impl EventBusBackendResource {
    pub fn read(&self) -> std::sync::RwLockReadGuard<'_, Box<dyn EventBusBackend>> {
        self.0.read().unwrap()
    }
    pub fn write(&self) -> std::sync::RwLockWriteGuard<'_, Box<dyn EventBusBackend>> {
        self.0.write().unwrap()
    }
}

impl Drop for EventBusBackendResource {
    fn drop(&mut self) {
        if Arc::strong_count(&self.0) != 1 {
            return;
        }

        if let Ok(mut backend) = self.0.write() {
            let _ = runtime::block_on(backend.disconnect());
        }
    }
}