Observable mit Zeitintervall nicht Ergebnisse bei subscribe

Question

Ich versuche, ein Zeitintervall zu dieser Observable-Sequenz hinzufügen (Das ist eine Ganzzahl-Sequenz in einer bestimmten Zeitspanne), aber es scheint nicht zu funktionieren. Wenn ich die Zeit entferne, dann funktioniert es Zeit. Wende ich den Timer falsch an?

var timer = Observable.Interval(TimeSpan.FromSeconds(2)).Take(4); 
var nums = Observable.Range(1,1200).Where(a => a % 2 == 0); 
var sourcenumbs = timer.SelectMany(nums); 


var results = sourcenumbs.Subscribe(
       x => Console.WriteLine("OnNext: {0}",x), 
       ex => Console.WriteLine("OnError: {0}",ex.Message), 
      () => Console.WriteLine("OnComplete") 
); 

Dieser Code zeigt keine Ausgabe an, wird es Dispose erhalten, bevor es das Subscribe erreicht?

Aber wenn ich einen Forloop mit einem Timer darin hatte, dann funktioniert es. Warum?

for (int i = 0; i < 10; i++) 
{ 
    Thread.Sleep(TimeSpan.FromSeconds(0.9)); 
} 

Answer 1

Ist das, was Sie wollen?

static void Main(string[] args) 
{ 
    Execute(); 

    Console.ReadKey(); 
} 

private static async void Execute() 
{ 
    var intervals = Observable.Interval(TimeSpan.FromSeconds(2)).StartWith(0); 
    var evenNumbers = Enumerable.Range(1, 1200).Where(a => a % 2 == 0); 

    var evenNumbersAtIntervals = intervals.Zip(evenNumbers, (_, num) => num); 

    try 
    { 
     await evenNumbersAtIntervals.ForEachAsync(
      x => Console.WriteLine("OnNext: {0}", x) 
     ); 

     Console.WriteLine("Complete"); 
    } 
    catch(Exception e) 
    { 
     Console.WriteLine("Exception " + e); 
    } 
} 

Beachten Sie, dass die Zahlen sind Enumerable und nicht Observable.