我想将IEnumerable集合转换为IObservable集合
不使用Rx ToObservable()和ToEnumerable()方法.
不使用Rx ToObservable()和ToEnumerable()方法.
解决方法
简单的答案 – 使用ToObservable.这就是它的用途.
“回答实际问题”答案 – 您可以避免通过Observable使用主题.创建:
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