psbus

适用于应用程序消息的通用发布/订阅模型

注意：此模块受到Lakelezz的（现已停止）hey_listen的极大启发：https://github.com/Lakelezz/hey_listen

psbus 允许任何应用程序实现自己的发布/订阅模型，以实现轻松的消息传递。目前 psbus 支持以下用例：

• 单线程事件调度
• 单线程+优先级事件调度
• 线程安全/同步事件调度
• 线程安全/同步+优先级事件调度

安装

将以下内容添加到您的 Cargo.toml

[dependencies]
psbus = "0.1.0"

示例

除了类型名称不同之外，调度器的使用在各个方面都是一致的。以下示例使用单线程、非优先级调度模型。

use psbus::{types::BusRequest, rc::{Event, Subscriber, Publisher, EventBus}};
use std::rc::Rc;

// Define the categories into which your events will fall
#[derive(Debug, Eq, PartialEq, Hash, Clone)]
pub enum TestEventType {
    Variant1,
    Variant2,
}

// Define the events themselves, note that you can use bare, tuple or struct enums all the same!
#[derive(Debug, Eq, PartialEq, Hash, Clone)]
pub enum TestEvent {
    ButtonPressed(u32),
    SomeOtherEvent,
}

// Implement the Event trait for your custom event
impl Event<TestEventType> for TestEvent {
    fn category(&self) -> TestEventType {
        match self {
            TestEvent::ButtonPressed(_) => TestEventType::Variant1,
            TestEvent::SomeOtherEvent => TestEventType::Variant2,
            // And more...
        }
    }
}

// Now lets make a test Subscriber...
pub struct TestSubscriber {
    id: Uuid,
}
impl Subscriber<TestEventType, TestEvent> for TestSubscriber {
    fn id(&self) -> &Uuid {
        &self.id
    }

    // ! Although we get a TestEvent enum, it is guaranteed to be only of the TestEventType that we are subscribed to
    fn on_event(&self, event: &ThermiteEvent) -> BusRequest {
        println!("Subscriber {} received event: {:?}", self.id, event);
        // What do we want to tell the bus to do after this subscriber is processed? For now, nothing... see crate::types::BusRequest for more actions
        BusRequest::NoActionNeeded
    }
}

// And a test Publisher...
pub struct TestPublisher {}
impl Publisher<TestEventType, TestEvent> for TestPublisher {
    // You can override the `publish_event` method here if you really want to...
}

// And finally, we define our EventBus type
pub type TestEventBus = EventBus<TestEventType, TestEvent>;

fn main() {
    // Again, what you wrap these datastructures with completely depends on your use case.
    let subscriber = Rc::new(TestSubscriber { id: Uuid::default() });
    let publisher = Rc::new(TestPublisher {});
    let bus = Rc::new(RefCell::new(TestEventBus::default()));

    // Subscribe our subscriber to receive any event falling under the `Variant1` category
    bus.try_borrow_mut().expect("Couldn't borrow event bus as mutable").subscribe(&subscriber, TestEventType::Variant1);

    // Publish an event to be received by the subscriber (NOTE: Call site here may vary depending on how you wrap your datastructures)
    publisher.publish_event(&TestEvent::ButtonPressed(1), &mut bus.try_borrow_mut().expect("Couldn't borrow event bus as mutable"));
}