如何将IEnumerable转换为IObservable? [英] how to convert IEnumerable to IObservable?

问题描述

我正在寻求将IEnumerable集合转换为IObservable的集合 而不使用Rx ToObservable()和ToEnumerable()方法.

I'm looking to convert an IEnumerable collection to an IObservable one without using Rx ToObservable() and ToEnumerable() methods.

推荐答案

简单答案-使用ToObservable.那就是它的目的.

Simple answer - use ToObservable. That's what it's for.

回答实际问题"答案-您可以避免通过Observable.Create使用Subjects:

"Answering the actual question" answer - you can avoid using Subjects via Observable.Create:

void Main()
{
    var src = Enumerable.Range(0, 10);
    var observable = Observable.Create<int>(obs =>
    {
        foreach(var item in src)
        {
            obs.OnNext(item);
        }
        return Disposable.Create(()=>{});
    });

    using(observable.Subscribe(Console.WriteLine))
    {
        Console.ReadLine();
    }
}

输出:

0
1
2
3
4
5
6
7
8
9

这篇关于如何将IEnumerable转换为IObservable?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！