none
Async IObservable enumerator

    Domanda

  • 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; }

    lunedì 13 febbraio 2012 03:44

Risposte

  • 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

    • Proposto come risposta Dave Sexton lunedì 13 febbraio 2012 04:31
    • Contrassegnato come risposta Tamas Flamich lunedì 13 febbraio 2012 13:02
    lunedì 13 febbraio 2012 04:25

Tutte le risposte