Struct InMemoryEventBus 

pub struct InMemoryEventBus { /* private fields */ }

内存事件总线实现（用于测试和轻量场景）。

Implementations

impl InMemoryEventBus

pub fn new() -> Self

创建空的内存事件总线

Trait Implementations

impl Default for InMemoryEventBus

fn default() -> Self

Returns the “default value” for a type.

impl EventBus for InMemoryEventBus

fn publish<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 PluginEvent, ) -> Pin<Box<dyn Future<Output = Result<EventId, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

发布事件，返回事件 ID。

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, event_type: &'life1 str, handler: Arc<dyn EventHandler>, ) -> Pin<Box<dyn Future<Output = Result<SubscriptionId, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

订阅事件，返回订阅 ID。

fn unsubscribe<'life0, 'async_trait>( &'life0 self, sub_id: SubscriptionId, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

取消订阅。

fn replay_pending<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

重放未投递事件（至少一次投递保障）。