在C#和System.Reactive中，如何用基于事件的类替换基于观察值的类？

在C#和System.Reactive中，基于事件的类和基于观察值的类在处理异步数据流时有不同的方式。基于事件的类通常使用事件和委托来通知订阅者发生了某些事情，而基于观察值的类则使用Observable序列来发布数据流。

如果你想用基于事件的类替换基于观察值的类，你需要理解两者的差异，并相应地调整代码结构。以下是一个简单的示例，展示如何进行这种转换。

基于观察值的类示例

假设你有一个基于观察值的类，它使用IObservable<int>来发布整数序列：

using System;
using System.Reactive.Linq;

public class ObservableCounter
{
    private IObservable<int> _observable;

    public ObservableCounter()
    {
        _observable = Observable.Interval(TimeSpan.FromSeconds(1)).Select(i => i);
    }

    public IObservable<int> Numbers => _observable;
}

基于事件的类示例

现在，我们将这个基于观察值的类转换为基于事件的类。我们将使用C#的事件和委托来实现这一点：

using System;

public class EventCounter
{
    // 定义一个委托
    public delegate void NumberEventHandler(object sender, NumberEventArgs e);

    // 定义一个事件
    public event NumberEventHandler NumberGenerated;

    private int _currentNumber;

    public EventCounter()
    {
        // 启动一个后台线程来生成数字并触发事件
        System.Threading.Thread thread = new System.Threading.Thread(() =>
        {
            while (true)
            {
                System.Threading.Thread.Sleep(TimeSpan.FromSeconds(1));
                _currentNumber++;
                NumberGenerated?.Invoke(this, new NumberEventArgs(_currentNumber));
            }
        });
        thread.Start();
    }
}

// 自定义事件参数类
public class NumberEventArgs : EventArgs
{
    public int Number { get; }

    public NumberEventArgs(int number)
    {
        Number = number;
    }
}

使用基于事件的类

要使用新的基于事件的类，你需要订阅其事件，就像处理常规C#事件一样：

public class Program
{
    public static void Main(string[] args)
    {
        EventCounter counter = new EventCounter();

        // 订阅事件
        counter.NumberGenerated += (sender, e) =>
        {
            Console.WriteLine("Generated number: " + e.Number);
        };

        // 让程序持续运行，以便我们可以看到事件被触发
        Console.ReadLine();
    }
}