WindowとSelectManyの直感的な説明

Question

windowとSelectManyを組み合わせた次の例を理解しようとしています。私が知る限り、Observableがアイテムを送信し始めるとすぐに、WindowはIObservableストリーム（IObservable<IObservable<T>>）を作成します。このストリームはSelectManyで平滑化され、<IObservable<T>になります。機能fがapplyiedされる。このvideo tutorialで

（「スレッド」と言ってみましょう）、新しいストリームが作成され、簡単なIObservableでSelectManyを使用して、。

質問：

1. あなたは、データをサブスクライブに到着し、何marble diagramは、ビデオチュートリアルに従っているかについて、いくつかの光を投げかけていただけますか？
2. ストリームをフラット化するために適用される関数は何ですか？
3. 最後に、SelectManyがRangeのような単純な関数を適用し、どのように結果が大理石図で表されているかという、より複雑な例を提供することは可能ですか？

ありがとうございます。

var source = Observable.Interval(TimeSpan.FromMilliseconds(100))// start a counter from zero and last 100 milliseconds 
     .Take(5) // take only the first 5 items 
     .Window(2) 
     .SelectMany(c => c); 

source.Subscribe(
    value => Console.WriteLine(value.ToString()), 
    error => Console.WriteLine(error.Message), 
    () => Console.WriteLine("Completed") 
); 

Console.WriteLine("Press any key to exit"); 
Console.ReadKey(); 

Answer 1

次のように上記のコードの各ステップのための大理石の図である。

interval: 0----1----2----3----4----5----6----7---- 
take5 : 0----1----2----3----4| 
window : W1--------W2--------W3| 
window1: 0----1| 
window2:   2----3| 
window3:      4| 
slctmny : 0----1----2----3----4| 

SelectMany

型TSourceの観察を受け取り、IObservable<TResult>オブジェクトに単一TSourceオブジェクトを変換セレクタ機能。セレクタ関数をすべての入力に適用してIObservable<IObservable<TResult>>を生成し、次に1つのIObservable<TResult>オブジェクトにフラット（マージ）します。 Rxの.SelectMany(selector)は、ほぼ.Select(selector).Merge()に相当します。したがって、SelectMany(o => o)通話をご利用の場合は、Merge通話と同じです。我々の場合には

、WindowはIObservable<IObservable<long>>を返しているので、TSourceはIObservable<long>を入力しています。セレクタ関数はIObservable<long>を返します。したがって、TResultはlongです。

Rangeを使用した例です。セレクタは{0}、{0,1}、{0,1,2}、{0,1,2,3}などのような観測値を返しますが、SelectManyあなたが観察できるものを得るので、それを平らに：正確に平坦にするために適用された機能は何ですか{0、0、1、0、1、2、0、1、2、3 ...}

var source = Observable.Interval(TimeSpan.FromMilliseconds(100))// start a counter from zero and last 100 milliseconds 
     .Take(5) // take only the first 5 items 
     .SelectMany(l => Observable.Range(0, (int)l));