反應性擴展：爲什麼這會立即退出？

Question

我在閱讀IntroToRx，我在示例代碼中遇到了一些問題。這裏是總和我的代碼：

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Reactive.Disposables; 
using System.Reactive.Linq; 
using System.Reactive.Subjects; 
using System.Text; 
using System.Threading; 
using System.Threading.Tasks; 

namespace LearningReactiveExtensions 
{ 
    public class Program 
    { 
    static void Main(string[] args) 
    { 
     var observable = Observable.Interval(TimeSpan.FromSeconds(5)); 
     observable.Subscribe(
      Console.WriteLine, 
     () => Console.WriteLine("Completed") 
     ); 
     Console.WriteLine("Done"); 
     Console.ReadKey(); 
    } 

    } 
} 

如果我理解正確的書，這應該寫數字序列到控制檯，每五秒鐘一次永遠因爲我從來沒有Dispose()序列。

但是，當我運行代碼時，我所得到的只是最後的「完成」。沒有數字，沒有「完成」，只有「完成」。

我在這裏做錯了什麼？

Answer 1

我假設你沒有耐心等待5秒鐘，否則你會看到代碼工作。

與Rx一起記住的主要想法是，Observable.Subscribe將幾乎立即返回控制到調用方法。換句話說，Observable.Subscribe不會阻止，直到結果產生。因此對Console.WriteLine的呼叫只會在五秒後被調用。

Answer 2

你需要一些方法讓主線程等待你正在做的事情。您可以使用一個信號，如果你喜歡

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Reactive.Disposables; 
using System.Reactive.Linq; 
using System.Reactive.Subjects; 
using System.Text; 
using System.Threading; 
using System.Threading.Tasks; 

namespace LearningReactiveExtensions 
{ 
    public class Program 
    { 
    static void Main(string[] args) 
    { 
     SemaphoreSlim ss = new SemaphoreSlim(1); 
     var observable = Observable.Interval(TimeSpan.FromSeconds(5)); 
     observable.Subscribe(
      Console.WriteLine, 
     () => { 
       Console.WriteLine("Completed"); 
       ss.Release(); 
      } 
     ); 
     ss.Wait(); 
     Console.WriteLine("Done"); 
     Console.ReadKey(); 
    } 

    } 
} 

雖然可能在這種情況下，只是爲了更好地寫

static void Main(string[] args) 
    { 
     SemaphoreSlim ss = new SemaphoreSlim(1); 
     Observable.Interval(TimeSpan.FromSeconds(5)).Wait(); 
     Console.WriteLine("Completed"); 
     Console.WriteLine("Done"); 
     Console.ReadKey(); 
    }