Rxjs отчетливые и массивы чисел

Question

Я не могу объяснить себе это

const something = new Rx.BehaviorSubject([1,2,4,4]) 
.distinct() 
.do((s) => console.log(s)) 
.map(list => list.length) 
.filter(length => length >=2) 
.subscribe(total => console.log('total:', total)); 

это то, что я получаю в качестве выходного

[1, 2, 4, 4] 
"total:" 
4 

я запутаться, потому что пересмотр документации на отчетливый я думал, что это будет работать для чисел. Мой пример использования - это виджет таблицы данных, который отправляет мне события, и этот массив отслеживает, какую строку они нажали, и я хочу обнаружить, как только дважды щелкнул.

обновленный код

const something = new Rx.BehaviorSubject([]); 

something.next ([1]); console.log (something.getValue()); something.next (something.getValue(). Concat (2)); something.next (something.getValue(). Concat (3)); something.next (something.getValue(). Concat (4)); something.next (something.getValue(). Concat (4));

.distinct() .subscribe (val => console.log ('значение:', val));

выход

"value:" 
[1, 2, 3, 4, 4] 

Answer 1

Вы посылаете значение, которое случается быть массивом. Вы бы видели операцию отличимым, если вы сделали

const something = new Rx.BehaviorSubject([]); 
something .distinct() .subscribe(val => console.log('value:', val)); 
something.next(1); // --> value: 1 
something.next(2); // --> value: 2 
something.next(1); // no output (because of distinct) 
something.next(3); // --> value: 3