Почему этот код не ведет себя асинхронно - PullRequest
Новая
       11

Почему этот код не ведет себя асинхронно

2 голосов
/ 08 сентября 2011

Как я понимаю, метод Subscribe должен быть асинхронным, тогда как Run - синхронным. Но этот кусок кода работает синхронно. Кто-нибудь может это исправить? 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Reactive.Linq;

namespace RxExtensionsDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            IObservable<int> source = Observable.Generate<int, int>(0, i => i < 10000, i => i + 1, i => i * i);

            IDisposable subscription = source.Subscribe(x => { Console.WriteLine("Received {0} from source", x); }, ex =>
            {
                Console.WriteLine("Error occured");

            }, () =>
            {
                Console.WriteLine("Source said there are no more messages to follow");
            });

            Console.WriteLine("Asynchronous");

            Console.ReadKey();
        }
    }
}

Я всегда вижу Asynchronous, записанный в консоли в последний раз.

1 Ответ

3 голосов
/ 08 сентября 2011

По умолчанию Observable.Generate использует Scheduler.CurrentThread.Однако вы можете указать другой планировщик для получения желаемого асинхронного поведения: 

IObservable<int> source = Observable.Generate<int, int>(
  0,
  i => i < 10000,
  i => i + 1,
  i => i * i,
  Scheduler.NewThread
);

Класс Scheduler находится в пространстве имен System.Reactive.Concurrency.

Другие возможные асинхронные предопределенные планировщики Scheduler.TaskPool и Scheduler.ThreadPool.

...