c# - 在 Rx 中安排周期性事件的正确方法是什么？

Question

我希望是一个简单的问题:我正在编写一个应用程序，我想在其中从数据库中检索数据；为此，我选择使用 Rx 将数据库表示为一系列值。

我只想每 5 秒最多轮询一次数据库(从而让我的观察者收到通知)。现在，我有这样的事情，其中​​调度程序正在安排一个周期性任务，使我的观察者订阅作为我的数据库的可观察对象:

_scheduler.SchedulePeriodic(_repository, TimeSpan.FromSeconds(5),
    (repo) => repo.AsObservable()
        .Where(item => _SomeFilter(item))
        .Subscribe(item => _SomeProcessFunction(item))
);

为简洁起见省略了函数名称等； repo.AsObservable()只是一个返回 IObservable<T> 的函数此时存储库中的所有项目。

现在，我认为这是正确的做事方式，但是在我想出这个解决方案之前，我确实想出了一个不同的解决方案，其中我有一个 Observable.Timer订阅的观察者将订阅 AsObservable()改为在每个计时器滴答时返回值。

我的问题是，这看起来非常……奇怪 - 为什么我要多次订阅可观察对象？

很抱歉，如果这个问题令人困惑，我在写它时感到困惑，但是调度程序也让我感到困惑:P

Answer 1

如果您使用内置运算符而不是手动安排任务会怎么样？

repo.AsObservable()
    .Where(_SomeFilter)
    // Wait 5 seconds before completing
    .Concat(Observable.Empty<T>().Delay(TimeSpan.FromSeconds(5))
    // Resubscribe indefinitely after source completes
    .Repeat()
    // Subscribe
    .Subscribe(_SomeProcessFunction);