以下の簡単なRx.NETで数字が表示されないのはなぜですか？

Question

using System; 
using System.Reactive; 
using System.Reactive.Linq; 
using System.Reactive.Subjects; 
using System.Threading.Tasks; 

namespace ConsoleApplication1 
{ 
    class Program 
    { 
     public static void Main() 
     { 
      Run().GetAwaiter().GetResult(); 
      Console.WriteLine("Press any key ..."); 
      Console.ReadKey(); 
     } 

     private static async Task Run() 
     { 
      await Task.Delay(1); 

      var dst = new Subject<int>(); 
      var res = dst 
       .SelectMany(async arg => 
       { 
        await Task.Delay(1); 
        Console.WriteLine(arg); 
        return Unit.Default; 
       }) 
       .DefaultIfEmpty(); 
      Observable.Range(0, 10).Subscribe(dst); 

      await res; 
     } 
    } 
} 

私は出力に10の数字を期待しますが、実際には何も得られません。どうして？

Answer 1

Observable.Range(0, 10).Subscribe(dst);が現在のスレッドで完了して実行されているため、await resと呼ばれるときには新しい値がありません。

コードから値を取得するには、（1）var dst = new ReplaySubject<int>();または（2）Observable.Range(0, 10).Delay(TimeSpan.FromSeconds(1.0)).Subscribe(dst);のいずれかを実行できます。

いずれにせよ、これは簡単なRxではありません。

---

私はので、私はそれがここに追加する価値があったと思った李氏のコメントは特によく書かれていたと思った：

すなわちObservable.Range(0, 10).Subscribe(dst);すぐ対象に10個の値をポンプ。次に、resでサブスクリプションを呼び出します。値はなくなりました。 Subject<T>は値をキャッシュしません。これはイベントを10回発生させてから、イベントハンドラをアタッチするようなものです。