Struct ObserverRegistry 

pub struct ObserverRegistry<T: Observable> { /* private fields */ }

观察者注册表

管理一组观察者并在状态变化时通知它们。注册表维护观察者的弱引用列表， 避免强引用循环导致的内存泄漏。

类型参数

• T: 被观察者类型，必须实现 Observable trait

设计特点

• 弱引用管理: 使用 Weak 引用存储观察者，允许观察者在不再需要时被释放
• 自动清理: 在通知时自动跳过已释放的观察者弱引用
• 通知策略: 支持两种通知策略
• 防止重复: 检查观察者是否已存在，防止重复添加

示例

use std::sync::Arc;
use rust_patterns_components::{Observable, Observer, ObserverRegistry, NotifyStrategy};

struct Sensor;

impl Observable for Sensor {
    type State = String;
    type Error = String;

    fn attach(&mut self, _observer: Arc<dyn Observer<Subject = Self>>) {}
    fn detach(&mut self, _observer: Arc<dyn Observer<Subject = Self>>) {}
}

let mut registry = ObserverRegistry::<Sensor>::default();
// 使用 registry.attach() 添加观察者
// 使用 registry.notify() 通知观察者

Implementations

impl<T> ObserverRegistry<T>

where T: Observable,

pub fn new() -> Self

创建新的观察者注册表实例

返回值

返回一个空的观察者注册表，不包含任何观察者。

pub fn with_capacity(capacity: usize) -> Self

创建具有初始容量的观察者注册表实例

参数

• capacity: 初始容量，用于预分配内存

返回值

返回一个具有指定初始容量的空注册表。

性能

预分配容量可以避免后续添加观察者时的多次内存重新分配， 当已知观察者数量时建议使用此方法。

pub fn attach(&mut self, observer: Arc<dyn Observer<Subject = T>>)

附加观察者

将观察者附加到注册表。方法内部会将观察者的强引用转换为弱引用， 并确保不会重复添加相同的观察者。

参数

• observer: 要附加的观察者强引用

注意

• 使用 Arc::downgrade 将强引用转换为弱引用，避免循环引用
• 使用 Weak::ptr_eq 检查观察者是否已存在，防止重复添加
• 观察者将在下次调用 notify 方法时收到状态更新通知

pub fn detach(&mut self, observer: Arc<dyn Observer<Subject = T>>)

分离观察者

从注册表中分离指定的观察者。分离后，该观察者将不再收到状态更新通知。

参数

• observer: 要分离的观察者强引用

注意

• 使用 Arc::downgrade 将强引用转换为弱引用进行匹配
• 使用 Weak::ptr_eq 进行引用相等性比较
• 如果观察者不存在于列表中，此方法不会有任何效果

pub fn notify( &self, state: &<T as Observable>::State, strategy: NotifyStrategy, ) -> Result<(), <T as Observable>::Error>

通知所有观察者

向所有有效的观察者发送状态更新通知。

参数

• state: 要通知的新状态引用
• strategy: 通知策略，指定观察者失败时的行为 使用 NotifyStrategy::StopOnError 或 NotifyStrategy::IgnoreError

返回值

• Ok(()): 所有观察者都成功处理了更新，或错误被忽略
• Err(<T as Observable>::Error): 某个观察者处理更新时返回了错误（当使用 StopOnError 策略时）

通知策略

根据指定的通知策略决定行为：

• NotifyStrategy::StopOnError: 立即返回第一个错误，停止通知其他观察者
• NotifyStrategy::IgnoreError: 忽略错误，继续通知其他观察者，总是返回 Ok(())

性能

此方法会自动清理无效的观察者弱引用（通过 Weak::upgrade 过滤）。

Trait Implementations

impl<T> Default for ObserverRegistry<T>

where T: Observable,

fn default() -> Self

创建默认的观察者注册表实例

等同于调用 ObserverRegistry::new()。