Rx: EnumerableEx.For() vs Enumerable.SelectMany()

Question

System.Interactive.dll includes a For() method with the following implementation:

IEnumerable<TResult> For<TSource, TResult>(
    IEnumerable<TSource> source,
    Func<TSource, IEnumerable<TResult>> resultSelector)
{
    return source.Select<TSource, IEnumerable<TResult>>(resultSelector).Concat<TResult>();
}

Am I missing something or is this equivalent to the existing Enumerable.SelectMany(), minus this?

IEnumerable<TResult> SelectMany<TSource, TResult>(
    this IEnumerable<TSource> source,
    Func<TSource, IEnumerable<TResult>> selector)

score 2 · Accepted Answer · answered Oct 06 '10 at 21:34

Good question. They produce the same results but the internal implementations are quite different.

EnumerableEx.For would have been added to System.Interactive to maintain duality between IObservable and IEnumerables. Note that Observable.For and Observable.SelectMany are different:

IObservable<TResult> For<TSource, TResult>(IEnumerable<TSource> source, Func<TSource, IObservable<TResult>> resultSelector)

vs.,

IObservable<TResult> SelectMany<TSource, TResult>(this IObservable<TSource> source, Func<TSource, IObservable<TResult>> selector)

Therefore you'd expect that EnumerableEx.For would have this signature, rather than the one it actually has:

IEnumerable<TResult> For<TSource, TResult>(**IObservable**<TSource> source, Func<TSource, IEnumerable<TResult>> resultSelector)

However, it obviously doesn't take an IObservable source. Perhaps it was meant to. I would ask your question in the Rx forums, to see if the Rx team has an answer.

Asked on the Rx forums: http://social.msdn.microsoft.com/Forums/en-US/rx/thread/48992ccb-d2dc-4de4-8525-d88ce8622554 — dahlbyk, Dec 05 '10 at 23:50

score 0 · Answer 2 · answered Oct 06 '10 at 17:45

They look like equivalent functionality to me. SelectMany is an extension method on an IEnumerable and .For is written as a static method on EnumerableEx, so they are called differently.

    foreach(var s in list.SelectMany(Filter))
    {
        // ...
    }

    foreach (var s in EnumerableEx.For(list, Filter))
    {
        // ...
    }

I'm sure there are specific reasons for using each one.

score 0 · Answer 3 · answered Feb 05 '11 at 15:27

0

My guess is that SelectMany traverses everything dynamically, whereas Concat (in For) traverses all of its outer IEnumerable elements before starting to register with and iterate over them.

In other words, Concat works with a fixed set of IEnumerable even if it receives them as an IEnumerable. Therefore, in For, the the entire set of IEnumerable is created before even returning the first TResult. In SelectMany, you receive a TResult instantly.

answered Feb 05 '11 at 15:27

akarnokd

69,132
14
157
192

Since all the operators involved (SelectMany, Select and Concat) are deferred, I'm not sure any difference in implementation would translate to a different end behavior. Some testing with side effects at various points in each operator's selector seems to always yield the same deferred result. – dahlbyk Feb 05 '11 at 23:58
In concat, you already know how many IEnumerable you need to work with, while in SelectMany, its amount depends on how many elements arrive from the source. For constant sized input sources, both should produce the same – akarnokd Feb 06 '11 at 21:25

Rx: EnumerableEx.For() vs Enumerable.SelectMany()

3 Answers3

Linked