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
33
34
35
36
37
38
39
40
41

use bevy::prelude::*;
use once_cell::sync::OnceCell;
use std::sync::Arc;
use tokio::runtime::{Builder, Runtime};

// Store an Arc so we can cheaply clone for the Bevy resource.
static RUNTIME: OnceCell<Arc<Runtime>> = OnceCell::new();

fn init_runtime() -> Arc<Runtime> {
    Arc::new(
        Builder::new_multi_thread()
            .enable_all()
            .build()
            .expect("Failed to build shared Tokio runtime"),
    )
}

/// Get a reference to the shared Tokio runtime (Arc inside OnceCell)
pub fn runtime() -> &'static Runtime {
    RUNTIME.get_or_init(init_runtime)
}

/// Block on a future using the shared runtime.
pub fn block_on<F: std::future::Future>(fut: F) -> F::Output {
    runtime().block_on(fut)
}

/// Bevy resource wrapper for a shared Tokio runtime (Arc for cheap clone into async tasks)
#[derive(Resource, Clone)]
pub struct SharedRuntime {
    pub runtime: Arc<Runtime>,
}

/// Ensure a SharedRuntime resource exists in the provided app.
pub fn ensure_runtime(app: &mut App) {
    if app.world().contains_resource::<SharedRuntime>() {
        return;
    }
    let arc = RUNTIME.get_or_init(init_runtime).clone();
    app.insert_resource(SharedRuntime { runtime: arc });
}