c# - 如何更改 IObservable 的值？

Question

我是 RX 的新手，现在我正在尝试做简单的事情 - 只是为 IObservable 设置一个新值(在我的例子中 T 是 double )。怎么做？

   public IObservable<double> TEST
    {
        get { return _test.NeededValue; }
        set { _test.NeededValue = value; } // I have add this, in order to change needed value
    }
    ...
    myObj.TEST = 0.1; // error 'Cannot convert double to System.IObservable<double>

Answer 1

这是让可观察对象产生值的最简单方法:

Subject<double> subject = new Subject<double>();
IObservable<double> observable = subject.AsObservable();
observable.Subscribe(x => Console.WriteLine(x));
subject.OnNext(42);

这将输出 42到控制台。

我添加了 IObservable<double> observable = subject.AsObservable(); 这一行展示你应该做什么，但作为一个Subject<T>也是一个 IObservable<T>你实际上可以这样做:

Subject<double> subject = new Subject<double>();
subject.Subscribe(x => Console.WriteLine(x));
subject.OnNext(42);

现在，这并不过分有趣。

这可能更符合您的需求:

void Main()
{
    var foo = new Foo();
    foo.Bars.Subscribe(x => Console.WriteLine(x));
    foo.OnBar(42);
}

public class Foo
{
    public event EventHandler<double> Bar;

    public void OnBar(double value)
    {
        this.Bar?.Invoke(this, value);
    }

    public IObservable<double> Bars
    {
        get
        {
            return
                Observable
                    .FromEventPattern<EventHandler<double>, double>(
                        h => this.Bar += h,
                        h => this.Bar -=h)
                    .Select(x => x.EventArgs);
        }
    }   
}

此代码还打印 42到控制台。