如何將項目緩存到無功擴展組中？

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

Answer 2

Buffer方法似乎做你想做的。給它TimeSpan，它會將所有消息合併到一個列表中。也有類似的Window方法，但我不完全確定它的語義可能是什麼。