Rx .NET中如何标记事件已处理或实现事件按引用传递？

你的问题核心是事件实例传递方式导致Handled属性修改无法同步到后续订阅者，下面分情况说明并给出修复方案：

1. 根本原因：值类型 vs 引用类型 #

如果你的IEvent是值类型（struct），每次传递事件时都会创建副本，CoreLayer中修改的是副本的Handled属性，原事件实例的Handled并未改变，因此UILayer收到的还是未标记为已处理的原实例。

如果IEvent已经是引用类型（class），问题大概率出在Rx过滤逻辑的执行时机或事件推送的线程同步上，但值类型导致的副本传递是最常见的诱因。

2. 解决方案：确保事件按引用传递 #

步骤1：将IEvent定义为引用类型 #

把IEvent的实现从struct改为class，这样所有订阅者操作的是同一个事件实例：

public interface IEvent
{
    bool Handled { get; set; }
    // 其他事件属性
}

// 示例事件类（必须是class）
public class WindowOpenedEvent : IEvent
{
    public bool Handled { get; set; }
    // 其他业务属性
}

步骤2：优化EventBus的推送逻辑（可选） #

当前的Where(e => !e.Handled)是在每个订阅的Observable管道中独立检查，对于跨Layer的顺序执行，这个逻辑有效，但可以在Publish阶段统一检查，避免不必要的事件推送：

public void Publish<T>(T @event) where T : IEvent
{
    foreach (var layer in _layerStack.Layers)
    {
        // 已处理则终止后续Layer的推送
        if (@event.Handled)
            break;
        
        if (_subjects.TryGetValue(layer, out var subject))
            subject.OnNext(@event);
    }
}

这样一旦某个Layer标记事件为已处理，后续Layer就不会收到该事件，减少无效推送。

步骤3：线程安全处理（异步场景必备） #

如果事件处理涉及异步操作（比如用SubscribeOn/ObserveOn切换线程），需要给Handled属性加原子操作保证线程安全：

public class WindowOpenedEvent : IEvent
{
    private int _handledFlag;
    public bool Handled
    {
        get => Interlocked.CompareExchange(ref _handledFlag, 1, 1) == 1;
        set
        {
            if (value)
                Interlocked.Exchange(ref _handledFlag, 1);
        }
    }
}

避免多线程环境下修改Handled时出现竞态条件。

3. 修复效果验证 #

修改完成后，CoreLayer处理事件时设置e.Handled = true，后续UILayer的订阅会因为事件实例的Handled为true，要么被Publish阶段的检查跳过，要么被订阅管道的Where过滤，不会执行日志输出。

内容的提问来源于stack exchange，提问作者ScottKane