8

我希望在我的一个视图模型中实现一些节流行为。这是一个 Silverlight 应用程序，但我认为这不是特别重要。

考虑一个具有三个属性的类：

  • 财产1
  • 财产2
  • 财产3

每当更新这些属性之一时，都需要进行刷新。

private void Refresh()
{
    //Call out to the server, do something when it comes back
}

我的目标如下：

  • 如果正在刷新，我们最好取消对服务器的调用，并发出新请求
  • 如果更改了属性，我们应该留出一些小时间窗口（可能是 0.1 秒）等待其他更改。这样，如果多个属性被快速更改（例如，以编程方式），我们就不会向服务器发送垃圾邮件请求。每次更改都可以重置 0.1 秒的窗口，但不是必需的。

如果重要的话，我正在使用 ChannelFactory 实现来进行服务器调用。

我可以使用什么样的模式来实现这一点？这是响应式扩展可以帮助我的东西吗？

编辑：

将保罗的答案标记为正确。虽然 ReactiveUI 目前不适用于 silverlight5，但它清楚地概述了使用 Rx 解决问题的方法/组合步骤。

4

1 回答 1

6

以下是使用 ReactiveUI 执行此操作的方法：

IObservable<TheData> FetchNewData() 
{
    // TODO: Implement me
}

this.WhenAny(x => x.Property1, x => x.Property2, x => x.Property3, (x,y,z) => Unit.Default)
    .Throttle(TimeSpan.FromMilliseconds(200), RxApp.DeferredScheduler)
    .Select(x => FetchNewData())
    .Switch()    // We only care about the req corresp. to latest values of Prop1-3
    .ToProperty(this, x => x.Data);

更新：以下是如何保证一次只运行一个，但需要注意的是您可能会得到无序的结果。

this.WhenAny(x => x.Property1, x => x.Property2, x => x.Property3, (x,y,z) => Unit.Default)
    .Throttle(TimeSpan.FromMilliseconds(200), RxApp.DeferredScheduler)
    .Select(_ => Observable.Defer(() => FetchNewData()))
    .Merge(1)
    .ToProperty(this, x => x.Data);

您描述的行为实际上可能是不可取的，因为如果属性不断变化，您最终会得到一个旧请求队列 - 如果您制作类似“BufferingSwitch()”运算符的东西，则可以优化它在确定没有变化之前没有返回结果——写起来真的很酷。

故事的寓意，Async Is Complicated™ :)

于 2012-06-15T18:46:34.633 回答