c# - 在 Reactive Extensions 中如何将项目缓冲到组中？

Question

我有一个 IObservable；其中属性更改具有实体 ID 和 PropertyName。我想用它来更新数据库，但如果多个属性几乎同时发生变化，我只想对同一实体的所有属性进行一次更新。

如果这是一个静态的 IEnumerable 而我使用的是 LINQ，我可以简单地使用:

MyList.GroupBy(C=>C.EntityID);

但是，列表永远不会终止(永远不会调用 IObserver.OnComplete)。我希望能够做的是等待一段时间，比如 1 秒，将所有调用适本地分组在那一秒内。

理想情况下，我会为每个 EntityID 设置单独的计数器，只要发现该 EntityID 的新属性更改，它们就会重置。

我不能使用 Throttle 之类的东西，因为我想处理所有的属性更改，我只想一次性处理它们。

Answer 1

给你:

MyObservable
    .Buffer(TimeSpan.FromSeconds(1.0))
    .Select(MyList =>
        MyList.GroupBy(C=>C.EntityID));