bevy_event_bus 0.2.0

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

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

use super::event_bus_backend::EventBusBackend;

/// 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()
    }
}