ebus 1.0.0

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

use async_trait::async_trait;
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<ExampleData> = 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.