Struct ChainedObserverFactory 

pub struct ChainedObserverFactory { /* private fields */ }

观察者链工厂

支持创建多个观察者，按顺序处理事件

使用场景

• 需要多个观察者协同工作
• 需要按优先级处理事件
• 需要组合不同的观察者功能

使用示例

use flare_core::server::events::factory::{ChainedObserverFactory, ServerMessageObserverFactory};

let factory1 = Arc::new(MyObserverFactory1::new());
let factory2 = Arc::new(MyObserverFactory2::new());

let chained = ChainedObserverFactory::new()
    .add_factory(factory1)
    .add_factory(factory2);

Implementations

impl ChainedObserverFactory

pub fn new() -> Self

创建新的链式工厂

pub fn add_factory(self, factory: Arc<dyn ServerMessageObserverFactory>) -> Self

添加工厂到链中

Trait Implementations

impl Default for ChainedObserverFactory

fn default() -> Self

Returns the “default value” for a type.

impl ServerMessageObserverFactory for ChainedObserverFactory

fn create_observer( &self, manager: Arc<ConnectionManager>, parser: MessageParser, event_handler: Arc<dyn ServerEventHandler>, connection_id: String, core_ref: Arc<ServerCoreRef>, core: Arc<ServerCore>, ) -> Arc<dyn ConnectionObserver>

为指定连接创建观察者