2016-08-19 2 views
1

Я хочу запустить .subscribe() для моего oberervable, если один из трех ключей объекта был изменен.RXJS - dinstinctUntilИзменить с несколькими клавишами

это работает, если я копирую & вставить метод для каждого ключа:

this.myService.loadData(this.dataContainer.id, true) 
     .distinctUntilChanged((updatedData) => { return updatedData.relations; }) 
     .subscribe(updatedData => { 
     console.log("relations changed",updatedData); 
    }); 

this.myService.loadData(this.dataContainer.id, true) 
     .distinctUntilChanged((updatedData) => { return updatedData.parent; }) 
     .subscribe(updatedData => { 
     console.log("parent changed",updatedData); 
    }); 

this.myService.loadData(this.dataContainer.id, true) 
     .distinctUntilChanged((updatedData) => { return updatedData.children; }) 
     .subscribe(updatedData => { 
     console.log("children changed",updatedData); 
    }); 

если я установил distinctUntilChanged компаратор вернуть весь updatedData объект, мой подписаться никогда не срабатывает.

Как я могу объединить три dinstinctUntilChanged в один редуктор?

ответ

0

Один из способов:

const data$ = this.myService.loadData(this.dataContainer.id, true); 

Observable 
    .combineLatest(
    $data.distinctUntilChanged(data => updatedData.relations), 
    $data.distinctUntilChanged(data => updatedData.parent), 
    $data.distinctUntilChanged(data => updatedData.children), 
    data => data 
) 
    .subscribe(updatedData => { 
    console.log("relation|parent|children changed", updatedData); 
    }); 
+0

идеальное решение, спасибо! –

0

Другим вариантом может быть вернуть все данные в селекторе, так и в функции сравнения, сравнить различные свойства:

this.myService.loadData(this.dataContainer.id, true) 
    .distinctUntilChanged((updatedData) => { return updatedData; }, (a, b) => { 
    return a.relations === b.relations && a.parent === b.parent && a.children === b.children; 
    }) 
    .subscribe(updatedData => { 
    console.log("updatedData", updatedData); 
}); 
0

я в конечном итоге делает :

.distinctUntilChanged((a, b) => a.key1 === b.key1 && a.key2 === b.key2); 
Смежные вопросы