Async IObservable enumerator

Question

I wonder if an extension method exists that could be used like this:

IObservable<T> observable = ...
IAsyncEnumerator<T> enumerator = observable.GetAsyncEnumerator();
while(await enumerator.MoveNext())   // Could rethrow OnError() exception
{
	T current = enumerator.Current;
}

Answer 1

I'd expect it would be called;

observable.ToAsyncEnumerable()

---

James Miles http://enumeratethis.com

Answer 2

Just checked. It's already in "Interactive Extensions" in the System.Interactive.Async.dll

public static IAsyncEnumerable<TSource> ToAsyncEnumerable<TSource>(this IObservable<TSource> source)

---

James Miles http://enumeratethis.com

Answer 3

Do you mean this? What is the point of separating features?
http://www.microsoft.com/download/en/details.aspx?id=27203

Does a stable release exist? I read something about that Rx and Ix was not separated before.

 

Answer 4

Ok, I found out that the stable version of Rx includes Ix too:
http://www.microsoft.com/download/en/details.aspx?id=24940

Answer 5

Hi,

Edit: Yes, it appears that your first link is the latest Ix release.

Your second link is a very old version of Rx.  It's not the official stable release.

Currently, Ix is only available in a separate assembly that is considered "experimental".

- Dave

---

http://davesexton.com/blog