问题描述
我有多个流进入我的客户端,一个在其创建时具有完整的实体。其他更新仅包含正在更新的字段而不是整个实体
我想使用更新消息中的 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 创建的现有条目?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)