bevy_event_bus 1.0.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

use bevy_event_bus::BusEvent;
use bevy_event_bus::config::EventBusConfig;
use bevy_event_bus::resources::EventWrapper;

#[cfg(feature = "kafka")]
pub mod kafka;

#[cfg(feature = "kafka")]
pub use kafka::{KafkaEventReader, KafkaReaderError};

#[cfg(feature = "redis")]
pub mod redis;
#[cfg(feature = "redis")]
pub use redis::{RedisEventReader, RedisReaderError};

/// Common capabilities shared by all bus event readers.
pub trait BusEventReader<T: BusEvent> {
    /// Drain the buffered events for the supplied configuration.
    fn read<C: EventBusConfig>(&mut self, config: &C) -> Vec<EventWrapper<T>>;
}