6

我有一个可观察的集合，我想继续向其提供对象，即使有人订阅了它，它们也应该到达观察者（这当然是可观察的主要目的）。我该怎么做？

在下面的程序中，订阅发生后，我想再输入 3 个应该到达观察者的数字。我该怎么做呢？

我不想通过实现IObservable<int>和使用Publish方法来实现自己的 Observable 类的路线？有没有其他方法可以实现这一目标？

public class Program
{
    static void Main(string[] args)
    {
        var collection = new List<double> { 1, 2, 3, 4, 5, 6, 7, 8, 9 };
        var observableCollection = collection.ToObservable();
        observableCollection.Subscribe(OnNext);
        //now I want to add 100, 101, 102 which should reach my observers
        //I know this wont' work
        collection.Add(100);
        collection.Add(101);
        collection.Add(102);
        Console.ReadLine();
    }

    private static void OnNext(double i)
    {
        Console.WriteLine("OnNext - {0}", i);
    }
}
4

1 回答 1

5

这就是我要做的：

    var subject = new Subject<double>();
    var collection = new List<double> { 1, 2, 3, 4, 5, 6, 7, 8, 9 };
    var observableCollection = collection
        .ToObservable()
        .Concat(subject); //at the end of the original collection, add the subject
    observableCollection.Subscribe(OnNext);

    //now I want to add 100, 101, 102 which should reach my observers
    subject.OnNext(100);
    subject.OnNext(101);
    subject.OnNext(102);

通常，如果您可以观察到产生额外输入的任何内容，您会想要连接该可观察的，而不是强制将这些值推送到主题中，但有时这是不切实际的。

于 2012-02-16T19:02:37.490 回答