如何从多个输入流更新 Observable Cache 中的现有条目

如何解决如何从多个输入流更新 Observable Cache 中的现有条目

我有多个流进入我的客户端，一个在其创建时具有完整的实体。其他更新仅包含正在更新的字段而不是整个实体

我想使用更新消息中的 Id 值应用事件：

class Foo { public string Id { get; set; } public string Bar { get; set;} }
class FooCreateUpdate { public Foo Entity { get; set; } public long Version { get; set; } }
class FooBarUpdate 
{
    public string Id { get; set; } 
    public string Bar { get; set; } // Bar is property of Foo
    public long Version { get; set; } 
} 

客户端操作：

public IAsyncEnumerable<FooCreateUpdate> SubscribetoFooCreateUpdates(){ /* ... */ }
public IAsyncEnumerable<FooBarUpdate> SubscribetoFooBarUpdates(){ /* ... */ }

缓存：

private readonly IObservableCache<Foo,string> _fooCache;

/* ... */

连接 observables 的 UI Init 代码（不确定如何在 FooBarUpdates 中添加）

_fooCache = _fooUpdatesClient.SubscribetoFooCreateUpdates()
   .ToObservable()
   .ToObservableChangeSet(e => e.Entity.Id)
   .AsObservableCache();

_fooCache
    .Connect()
    .ObserveOn(RxApp.MainThreadScheduler)
    .disposeMany()
    .Bind(out _fooItems)
    .Subscribe();

如何同时订阅两者，例如 FooCreateUpdate 将创建新条目，而 FooBarUpdate 将更新由 FooCreate 创建的现有条目？