Repository files navigation

This is a small Eventbus implementation that can be used to asynchronously transmit data to subscribers of a EventBus instance.

• To build the lib run:cargo build --release
• To run the example run:cargo run --example basic-implementation

use ebus::{async_subscriber,EventBus,Subscriber};#[derive(Default)]pubstructExampleSubscriber;#[async_subscriber]implSubscriberforExampleSubscriber{typeInput =String;asyncfnon_event_publish(&mutself,event:&Self::Input){println!("Received Data: {:#?}", event);}}#[tokio::main]asyncfnmain(){// Create a new event busletmut event_bus =EventBus::default();// Create a new subscriber and subscribe it to the event buslet subscriber =ExampleSubscriber::default();    event_bus.subscribe(subscriber);// Create an event and queue it for processinglet event_data ="Hello World!".to_owned();    event_bus.queue_and_process(event_data).await;}

See theopen issues for a full list of proposed features (and known issues).

If you have a suggestion that would make this better, please fork the repo and create a pull request. You can also simply open an issue with the tag "enhancement".

1. Fork the Project
2. Create your Feature Branch (git checkout -b feat(amazing)/amazing-feature)
3. Commit your Changes (git commit -m 'feat(amazing): such progress')
4. Push to the Branch (git push origin feat(amazing)/amazing-feature)
5. Open a Pull Request

Distributed under the MIT or Apache 2 License. SeeLICENSE-MIT orLICENSE-APACHE for more information.