Rx в .Net 3.5 не асинхронный?

Question

Я играю с Rx в .Net3.5SP1 и пробовал 101 Rx Samples. Я пытаюсь выполнить первый пример (Start - Run Code Asynchronously), но он, похоже, не работает асинхронно. Например,

 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]"); 

Выходы

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

Есть ли объяснение этому? Я делаю что-то неправильно? Это ожидаемое поведение?

UPDATE

я бы подумал, что сказал бы

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

Но основной поток блокируется, а якобы асинхронная вызов происходит.

Answer 1

Это выглядит разумно ожидаемым для меня.

Если вы положили вызов Thread.Sleep между «Созданным» и «Запуск», я думаю, вы увидите строку «Вычисление», показывающую, что она выполняет работу во время работы основного потока. Именно так он асинхронен.

Если вы обеспокоены тем, что First() возвращает само значение, а не дает своеобразное «будущее» значение, которое вы можете проконсультировать позже, это другое дело - и у меня есть две записи в блоге, которые вы можете прочитать: part 1; part 2. I думаю вы хотите метод Prune, но я не совсем уверен.

Answer 2

В строке // subscribe and wait for completion of background operation указано, что она ждет завершения операции фона. Таким образом, вы не ожидаете, что код, следующий за этой строкой (Console.WriteLine("[Started]");), будет выполняться до завершения операции, не так ли?

Answer 3

Первый блокирует ... Подписаться что вы хотите:

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