Struct EventBus 

pub struct EventBus<ContentType, TopicId: PartialEq + Clone> { /* private fields */ }

The Event Bus itself. Add subscribers and publishers to it.

Implementations

impl<ContentType, TopicId: PartialEq + Clone> EventBus<ContentType, TopicId>

pub fn new() -> Self

Examples found in repository

examples/basic_game_events/main.rs (line 14)

fn main() {
    // Create a bus
    let bus: EventBus<Commands, TopicIds> = EventBus::new();

    // Create players, input, and attach to the bus
    let player1 = Player { id: 1 };
    let player2 = Player { id: 2 };
    let mut input = Input::new();

    bus.add_subscriber(player1);
    bus.add_subscriber(player2);
    bus.add_publisher(&mut input, Some(85)).unwrap();

    // Send some events
    input.publish(Commands::Move { dx: 1.0, dy: 2.0 }, Some(TopicIds::Player2));
    input.publish(Commands::Move { dx: 1.0, dy: 2.0 }, Some(TopicIds::Player1));
    input.publish(Commands::Atack, Some(TopicIds::Player2));
    input.publish(Commands::Atack, Some(TopicIds::Player1));
}

pub fn add_subscriber_shared( &self, subscriber: Arc<Mutex<dyn Subscriber<ContentType, TopicId>>>, )

pub fn add_subscriber<S>(&self, subscriber: S)

where S: Subscriber<ContentType, TopicId> + 'static,

Examples found in repository

examples/basic_game_events/main.rs (line 21)

fn main() {
    // Create a bus
    let bus: EventBus<Commands, TopicIds> = EventBus::new();

    // Create players, input, and attach to the bus
    let player1 = Player { id: 1 };
    let player2 = Player { id: 2 };
    let mut input = Input::new();

    bus.add_subscriber(player1);
    bus.add_subscriber(player2);
    bus.add_publisher(&mut input, Some(85)).unwrap();

    // Send some events
    input.publish(Commands::Move { dx: 1.0, dy: 2.0 }, Some(TopicIds::Player2));
    input.publish(Commands::Move { dx: 1.0, dy: 2.0 }, Some(TopicIds::Player1));
    input.publish(Commands::Atack, Some(TopicIds::Player2));
    input.publish(Commands::Atack, Some(TopicIds::Player1));
}

pub fn add_publisher( &self, publisher: &mut dyn Publisher<ContentType, TopicId>, source_id: Option<u64>, ) -> Result<(), &'static str>

Add a publisher to the event bus. If source_id is None, the publisher will be assigned a unique id.

Examples found in repository

examples/basic_game_events/main.rs (line 23)

fn main() {
    // Create a bus
    let bus: EventBus<Commands, TopicIds> = EventBus::new();

    // Create players, input, and attach to the bus
    let player1 = Player { id: 1 };
    let player2 = Player { id: 2 };
    let mut input = Input::new();

    bus.add_subscriber(player1);
    bus.add_subscriber(player2);
    bus.add_publisher(&mut input, Some(85)).unwrap();

    // Send some events
    input.publish(Commands::Move { dx: 1.0, dy: 2.0 }, Some(TopicIds::Player2));
    input.publish(Commands::Move { dx: 1.0, dy: 2.0 }, Some(TopicIds::Player1));
    input.publish(Commands::Atack, Some(TopicIds::Player2));
    input.publish(Commands::Atack, Some(TopicIds::Player1));
}

pub fn publish( &self, event: ContentType, topic_id: Option<TopicId>, source_id: u64, )

pub fn get_internal(&self) -> Arc<EventBusInternal<ContentType, TopicId>>