Lib.rs

基本示例

use ebus::{async_subscriber, EventBus, Subscriber};

#[derive(Default)]
pub struct ExampleSubscriber;

#[async_subscriber]
impl Subscriber for ExampleSubscriber {
    type Input = String;

    async fn on_event_publish(&mut self, event: &Self::Input) {
        println!("Received Data: {:#?}", event);
    }
}

#[tokio::main]
async fn main() {
    // Create a new event bus
    let mut event_bus = EventBus::default();

    // Create a new subscriber and subscribe it to the event bus
    let subscriber = ExampleSubscriber::default();
    event_bus.subscribe(subscriber);

    // Create an event and queue it for processing
    let event_data = "Hello World!".to_owned();
    event_bus.queue_and_process(event_data).await;
}

路线图

查看 开放问题 以获取建议功能（和已知问题的）完整列表。

贡献

如果您有改进此项目的建议，请fork存储库并创建一个pull请求。您还可以简单地打开一个带有“enhancement”标签的问题。

1. fork 项目
2. 创建您的功能分支（git checkout -b feat(amazing)/amazing-feature）
3. 提交您的更改（git commit -m 'feat(amazing): such progress'）
4. 将更改推送到分支（git push origin feat(amazing)/amazing-feature）
5. 打开一个pull请求

许可证

在MIT或Apache 2许可证下分发。有关更多信息，请参阅LICENSE-MIT或LICENSE-APACHE。