訂閱布爾狀態使用Rx

Question

我有一個IObservable<bool>，我希望在最後一個n項目設置爲true時得到通知。

對於像我想要的東西：

MyBool.Buffer(10).SelectMany(x => x).All(x => x).Subscribe(x => /*do something*/); 

但它只能觸發一次;似乎OnCompleted被解僱了。

Answer 1

您正在有效地緩衝和展平您的可觀察值。調用.Buffer(10).SelectMany(x => x)就像是一種非手術，因爲它發出的什麼都去

你需要做的是更多這樣的：

MyBool 
     .Buffer(10, 1) 
     .Select(xs => xs.All(x => x)) 
     .Where(x => x); 

我假設你想知道，每當有10個trues在排，如果有11個，你會得到兩次通知。

---

背後Buffer(10, 1)的原因是這樣Buffer作品 - 這給10元素的緩衝區，並沿着1移動。如果我做了Buffer(10)，我會得到10個元素，然後移動十個元素。

如果我是Observable.Range(0, 5).Buffer(3)我得到{0, 1, 2}, {3, 4}，但如果我做了Observable.Range(0, 5).Buffer(3, 1)我得到{0, 1, 2}, {1, 2, 3}, {2, 3, 4}, {3, 4}, {4}。

如果你想知道當一個false來通後trues那就試試這個：

MyBool 
     .Buffer(3, 1) 
     .Select(xs => xs.All(x => x)) 
     .Buffer(2, 1) 
     .Where(x => x[0] || x[1]); 

這給了這些可能的組合：