bevy_event_bus 1.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
28
29
30
31
32

use bevy::prelude::*;

use crate::backends::EventBusBackend;
use crate::plugins::event_bus::setup::{
    connect_and_install_backend, ensure_app_runtime, register_backend, register_plugin_world,
};

/// Wires a broker backend into Bevy (runtime, drain systems, lifecycle).
pub struct EventBusPlugin<B: EventBusBackend> {
    backend: B,
}

impl<B: EventBusBackend> EventBusPlugin<B> {
    pub fn new(backend: B) -> Self {
        Self { backend }
    }
}

impl<B: EventBusBackend> From<B> for EventBusPlugin<B> {
    fn from(backend: B) -> Self {
        Self::new(backend)
    }
}

impl<B: EventBusBackend> Plugin for EventBusPlugin<B> {
    fn build(&self, app: &mut App) {
        ensure_app_runtime(app);
        register_plugin_world(app);
        register_backend(app, &self.backend);
        connect_and_install_backend(app);
    }
}