bevy_event_bus 1.1.3

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
41
42
43
44
45
46

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 backend: Arc<RwLock<Box<dyn EventBusBackend>>>,
}

impl EventBusBackendResource {
    pub fn new<B: EventBusBackend>(backend: B) -> Self {
        Self {
            backend: Arc::new(RwLock::new(Box::new(backend))),
        }
    }
    pub fn from_box(boxed: Box<dyn EventBusBackend>) -> Self {
        Self {
            backend: 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.backend.read().unwrap()
    }
    pub fn write(&self) -> std::sync::RwLockWriteGuard<'_, Box<dyn EventBusBackend>> {
        self.backend.write().unwrap()
    }
}

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

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