1

我有一些代码,需要让它与最新的 RX 一起工作。我已经看到建议使用 Create 而不是 Iterate 但我不知道如何使用 Create 可以帮助解决这个问题吗?

IEnumerable<IObservable<Object>> sequence = ...;

disposable = Observable.Iterate(sequence)
            .Subscribe(
                next => { },
                exception,
                ()=>completed(_result));

更新:

评论中有一个指向 social.msdn 的链接,我已经看过这个帖子,但没有找到解决方案。他们只提供了一些建议。不幸的是,我不熟悉 RX。

4

1 回答 1

0
IEnumerable<IObservable<Object>> sequence;

sequence.ToObservable()
    .Concat()
    .Subscribe(x => /* ... */);
于 2013-01-08T05:19:53.053 回答