观察要添加到 RX 中的列表中的项目

Question

我正在尝试让一个简单的演示工作。

我有一个字符串集合，我想观察它的添加，而不使用任何控制事件代码。不知何故，我得到的印象是，也许是错误的，Rx 或 .Net 的其他部分支持这一点，而无需连接所有（可能或可能不会）将成员添加到集合的各种事件。

如果我用间隔替换我的source，就像在注释掉的代码中一样，委托会被调用（ala，var source = Observable.Interval(TimeSpan.FromSeconds(1)); .这给了我希望，我可以在这里做我想做的事，也许是错误的。

基本示例来自创建和订阅简单可观察序列

在下面的代码中，我要做的是直接观察source集合（而不是通过控件事件），并在将项添加到集合时调用委托。

我宁愿不绕过 LINQ 或 RX，如果它们确实支持我的论点，即它们支持此功能。

using Microsoft.VisualBasic;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.Collections.ObjectModel;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using System.Threading;
public class frmRx
{
    ObservableCollection<string> ObservableCollection = new ObservableCollection<string>();
    Dim source = Observable.ToObservable(ObservableCollection).ObserveOn(SynchronizationContext.Current)
    //this code worked, but it's not a collection I made
    //source = Observable.Interval(TimeSpan.FromSeconds(1)).Select(x => x.ToString).ObserveOn(SynchronizationContext.Current);
    private void frmRx_Load(System.Object sender, System.EventArgs e)
    {
        IConnectableObservable<string> Publication = Observable.Publish<string>(source);
        Publication.Subscribe(x => { AddToTreeView(x); }, ex => { }, () => { });
        Publication.Connect();
    }
    private void AddToTreeView(string Text)
    {
        TreeView1.Nodes.Add(Text); //this never gets called
    }
    // this is just my test way of adding a member to the collection.
    // but the adding could happen anywhere,
    // and I want to watch the collection changes regardless of how it came about
    private void TextBox1_TextChanged(System.Object sender, System.EventArgs e)
    {
        ObservableCollection.Add(TextBox1.Text.Last);
    }
    public frmRx()
    {
        Load += frmRx_Load;
       TextBox1.TextChanged += TextBox1_TextChanged;
        }
    }

Answer 1

您犯了一个错误，即Observable.ToObservable(ObservableCollection)将创建一个IObservable<string>，该将为ObservableCollection的未来更新生成值。

它没有。

.ToObservable(...) 扩展方法只是将IEnumerable<>转换为并IObservable<>，以便在订阅可观察量时枚举值。

如果您希望将新值推送给订阅者，则需要使用Subject<string>。

此外，您的代码并不像那么简单。你为什么要在发布可观察量方面胡思乱想？

以下是您可以编写的最简单的代码来使其工作：

public class frmRx
{
    private Subject<string> source = new Subject<string>();
    public frmRx()
    {
        source.ObserveOn(this).Subscribe(x => TreeView1.Nodes.Add(x));
        TextBox1.TextChanged += (s, e) => source.OnNext(TextBox1.Text);
    }
}

我已经包括了.ObserveOn(this)，因为将它们放入是一个好习惯，但在这种情况下不需要它。

不过，我更希望看到的是：

public class frmRx
{
    public frmRx()
    {
        Observable
            .FromEventPattern(
                h => textBox1.TextChanged += h,
                h => textBox1.TextChanged -= h)
            .Select(x => textBox1.Text)
            .Subscribe(x => treeView1.Nodes.Add(x));
    }
}

这避免了主题，并且在强类型时尽可能简单。

甚至最好更进一步，在关闭时更好地清理您的订阅，如下所示：

        var subscription =
            Observable
                .FromEventPattern(
                    h => textBox1.TextChanged += h,
                    h => textBox1.TextChanged -= h)
                .Select(x => textBox1.Text)
                .Subscribe(x => treeView1.Nodes.Add(x));
        this.FormClosing += (s, e) => subscription.Dispose();

Answer 2

最简单的方法是使用 Rx.net 框架，如ReactiveUI。我将向你们展示这将如何运作。

ReactiveList<string> _collection = new ReactiveList<string>();
public Constructor()
{
     var subscription = _collection.ItemsAdded.Subject(added => doSomething(added));
     this.Disposed += (o, e) => subscription.Dispose();
}

在这里，您需要多少代码才能使其在没有第三方的情况下"工作"。此外，此代码中根本没有异常处理。

public class ViewModel
{
    private ObservableCollection<string> _source = new ObservableCollection<string>();
    public ViewModel()
    {
        //There will be issues with the exception handling
        Observable.FromEventPattern
            <NotifyCollectionChangedEventHandler, NotifyCollectionChangedEventArgs>
            (x => _source.CollectionChanged += x, x => _source.CollectionChanged -= x)
            .Where(x => x.EventArgs.Action == NotifyCollectionChangedAction.Add)
            .SelectMany(x => x.EventArgs.NewItems.Cast<string>())
            .Subscribe(AddToTreeView);
    }
    public void AddToTreeView(string text)
    {
        TreeView1.Nodes.Add(text);
    }
}