About The Project

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

Built With

• Rust
• async-trait
• uuid

Prerequisites

• Rust

Usage

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

Basic Example

```rust use asynctrait::asynctrait; use ebus::{bus::EventBus, event::Event, subscriber::EventBusSubscriber};

[derive(Clone, Debug)]

pub struct ExampleData { pub data: String, }

pub struct ExampleDataSubscriber { data: ExampleData, }

[async_trait]

impl EventBusSubscriber for ExampleDataSubscriber { type InputDataType = ExampleData;

async fn on_event_publish(&mut self, event: &Event<Self::InputDataType>) {
    let data = event.data.to_owned();

    println!("Received Data: {:#?}", data);

    self.data = data;
}

}

[tokio::main]

async fn main() { let mut example_bus: EventBus = EventBus::default();

let subscriber = ExampleDataSubscriber {
    data: ExampleData {
        data: "".to_owned(),
    },
};

example_bus.subscribe(subscriber);

example_bus
    .publish_and_process(Event::new(ExampleData {
        data: "I am Data".to_owned(),
    }))
    .await;

} ```

Roadmap

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

Contributing

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 feature/AmazingFeature)
3. Commit your Changes (git commit -m 'Add some AmazingFeature')
4. Push to the Branch (git push origin feature/AmazingFeature)
5. Open a Pull Request

License

Distributed under the MIT License. See LICENSE for more information.