Struct Subject 

pub struct Subject<T, E> { /* private fields */ }

主题（被观察者）

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

类型参数

• T: 状态类型，必须与观察者的 State 类型匹配
• E: 错误类型，必须与观察者的 Error 类型匹配

设计特点

• 弱引用管理: 使用 Weak 引用存储观察者，允许观察者在不再需要时被释放
• 自动清理: 可选地自动清理已释放的观察者弱引用
• 通知策略: 支持两种通知策略

Implementations

impl<T, E> Subject<T, E>

pub fn new() -> Self

创建新的主题实例

返回值

返回一个空的主题，不包含任何观察者。

pub fn with_capacity(capacity: usize) -> Self

创建具有初始容量的主题实例

参数

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

返回值

返回一个具有指定初始容量的空主题。

性能

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

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

附加观察者

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

参数

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

注意

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

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

分离观察者

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

参数

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

注意

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

pub fn notify(&self, state: &T, strategy: NotifyStrategy) -> Result<(), E>

通知所有观察者

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

参数

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

返回值

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

通知策略

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

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

Trait Implementations

impl<T, E> Default for Subject<T, E>

fn default() -> Self

创建默认的主题实例

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