可观察的时间间隔不显示订阅结果

Question

我正在尝试向这个 Observable 序列添加一个时间间隔（即在特定时间跨度产生一个整数序列），但它似乎不起作用。当我删除时间时，它的工作时间。我是否错误地应用了计时器？

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

此代码不显示任何输出，是否在到达订阅前得到 Dispose？

但是，如果我有一个带有计时器的 forloop，那么它就可以工作。为什么？

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

Answer 1

这是你想要的吗？

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

请注意，数字是 Enumerable 而不是 Observable。