使用來自IObservable的最新值

Question

我得到了Foo,Bar和Baz類型的IObservable。此外，有一個定義爲一個方法：

void DoWork(Foo foo); 

的IObservable在別處定義爲Subject和OnNext被稱爲不時。

只要有新的數據可用（由某些Where查詢定義），我想調用DoWork方法以及最新的Foo值。如果沒有生成Foo值，則不應調用該方法。

最簡單的方法是什麼？

更具體一些，請看下面的例子。我想打電話DoWork時bar或baz變化，與最新的foo（f.id == 1）：

void Wire(IObservable<Foo> foo, IObservable<Bar> bar, IObservable<Baz> baz) 
{ 
    foo.Where(f => f.Id == 1) 
     .Subscribe(f => DoWork(f)); 
} 

Answer 1

這適用於me：

var ubar = bar.Select(x => Unit.Default); 
var ubaz = baz.Select(x => Unit.Default); 

ubar.Merge(ubaz) 
    .CombineLatest(foo.Where(f => f.Id == 1), (u, f) => f) 
    .Subscribe(f => DoWork(f)); 

Answer 2

您可以在Observable class使用Do extension method做到這一點：

IObservable<Foo> filteredList = foos.Where(...); 

// Invoke DoWork on each instance of Foo. 
filteredList.Do(DoWork);