rolandpheasant / dynamicdata.reactiveui Goto Github PK

 [Test]
        public void DuplicatingResult()
        {
            
            _source.Add(new Person("Adult1", 47));
            _source.Add(new Person("Adult2", 48));
            _source.Add(new Person("Adult3", 49));
            _source.Add(new Person("Adult4", 150));
            _source.Add(new Person("Adult5", 150));
            _source.Add(new Person("Adult6", 150));
            _source.Add(new Person("Adult7", 150));
            _source.Add(new Person("Adult8", 150));

            Subject<int> ageTofilter = new Subject<int>();
            ObservableCollectionExtended<Person> nonReactiveListBinding = new ObservableCollectionExtended<Person>();
            
            var passengerFilter =
                ageTofilter
                    .Select(data =>
                    {
                        Func<Person, bool> filter = (twp) =>
                        {
                            return twp.Age == data;
                        };

                        return filter;
                    });
            
            _source
                .Connect()
                .Filter(passengerFilter)
                .Bind(nonReactiveListBinding)
                .Bind(_collection)
                .Subscribe();
            
            //this passes
            Assert.AreEqual(8, _collection.Count);
            
            //Change the filter
            ageTofilter.OnNext(150);
            
            //this passes
            Assert.AreEqual(5, nonReactiveListBinding.Count);
            
            
            //this fails with a result of 13. Items are being duplicated
            //into the reactivelist
            Assert.AreEqual(5, _collection.Count);
            
        }