Я сделал следующий наблюдение, что фильтры только изменения для данного ресурсаида: < /p>
var valueChangesObs = events
.GroupBy(e => e.ResourceId)
.SelectMany(e => e.DistinctUntilChanged(e => e.ResouceValue))
Тем не менее, сверхурочно будет слишком много групп, и мне нужно их чистить. Имея в виду: < /p>
var valueChangesObs = events
.GroupBy(x => x.ResourceId)
.TakeUntil(group => g))
.SelectMany(group => group
.DistinctUntilChanged(x => x.ResouceValue)
.TakeUntil(x => resourceDeprecatedObservable.First(y => y.ResourceId = x.ResourceId)));
Подробнее здесь: https://stackoverflow.com/questions/795 ... by-groupby