Rx in .Net 3.5 nicht asynchron?

Question

Ich spiele mit Rx in. Net3.5SP1 und versuche die 101 Rx Samples. Ich versuche das erste Beispiel (Start - Code asynchron ausführen), aber es scheint nicht wirklich asynchron zu laufen. Zum Beispiel

 Console.WriteLine("[Creating]"); 
     var o = Observable.Start(() => 
     { 
      Console.WriteLine("Calculating..."); 
      Thread.Sleep(3000); 
      Console.WriteLine("Done."); 
     }); 
     Console.WriteLine("[Created]"); 
     Console.WriteLine("[Starting]"); 
     o.First(); // subscribe and wait for completion of background operation 
     Console.WriteLine("[Started]"); 

Ausgänge

[Creating] 
[Created] 
[Starting] 
Calculating... 
    <...3 Second Wait...> 
Done. 
[Started] 

Gibt es eine Erklärung dafür? Mache ich etwas falsch? Ist das erwartetes Verhalten?

UPDATE

ich es gesagt haben

[Creating] 
[Created] 
[Starting] 
Calculating... 
[Started] 
    <...3 Second Wait...> 
Done. 

Aber der Haupt-Thread blockiert wird, während die angeblich Asynch Anruf passiert wäre hätte gedacht.

Answer 1

Das sieht vernünftigerweise zu mir erwartet.

Wenn Sie einen Thread.Sleep Anruf zwischen "Created" und "Starting" setzen, denke ich, dass die Zeile "Calculating" angezeigt wird, die zeigt, dass sie funktioniert, während der Hauptthread ausgeführt wird. So ist es asynchron.

Wenn Sie besorgt sind, weil First() den Wert selbst zurückgibt, anstatt eine Art "zukünftigen" Wert zu geben, können Sie später nachsehen, das ist eine andere Sache - und ich habe zwei Blogbeiträge für Sie zu lesen: part 1; part 2. I denke, Sie wollen die Prune Methode, aber ich bin mir nicht ganz sicher.

Answer 2

Die Zeile // subscribe and wait for completion of background operation besagt, dass sie auf den Abschluss der Hintergrundoperation wartet. Sie würden also nicht erwarten, dass der Code, der dieser Zeile folgt (Console.WriteLine("[Started]");), so lange läuft, bis der Vorgang abgeschlossen ist, oder?

Answer 3

Zuerst blockiert ... Abonnieren ist das, was Sie wollen:

 public static void Main(string[] args) { 

     Console.WriteLine("[Creating]"); 
     var o = Observable.Start(() => 
     { 
      Console.WriteLine("Calculating..."); 
      Thread.Sleep(3000); 

     }); 
     Console.WriteLine("[Created]"); 
     Console.WriteLine("[Starting]"); 

     o.Subscribe(_ => Console.WriteLine("Done.")); // subscribe and wait for completion of background operation 

     Console.WriteLine("[Started]"); 

     Console.ReadKey(); 
    }