反应性扩展：为什么这会立即退出？

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(); 
    }