使用 IObservable 的最新值

Question

我有三个类型为 Foo、Bar 和 Baz 的 IObservable。另外，还有一个方法定义为：

void DoWork(Foo foo);

IObservable在别处定义为Subject，OnNext不时被调用。

每当新数据可用（由某些Where查询定义）时，我想使用最新的Foo值调用DoWork方法。如果没有生成 Foo 值，则不应调用该方法。

最简单的方法是什么？

更具体地说，请参阅以下示例。我想在 bar 或 baz 更改时调用 DoWork，并使用最新的 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

这对我有用：

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

您可以使用执行 rel="nofollow">Observable 类 来执行此操作：

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

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