相关疑难解决方法(0)

通常,当您订阅值的更改时,您也有兴趣知道初始值.我希望我的IObservable缓存最新(或初始)值并在订阅时推送该值.

当使用普通事件时,我经常会得到看起来像的代码

x.SomeEvent += SomeEventHandler;
SomeEventHandler(x, EventArgs.Empty);

使用IObservable我希望用推送初始值的东西包装事件.如果我有多个订阅者,他们应该在订阅时收到最新的值我有一些代码,如果我在创建IObservable之后立即订阅,但是如果事件在订阅之前触发则不会:

class Program
{
    static void Main()
    {
        var s = new Source { Value = 1 };
        var values = Observable.Return(s.Value).Concat(
            Observable.FromEvent(
                h => s.ValueChanged += h,
                h => s.ValueChanged -= h)
            .Select(_ => s.Value));
        using (values.Subscribe(Console.WriteLine))
        {
            s.Value = 2; // prints 1,2 as expected
        }
        using (values.Subscribe(Console.WriteLine))
        {
            s.Value = 3; // prints 1,3 - expected 2,3
        }
    }
}

class Source
{
    private int _value;
    public int Value
    { …