WhenAnyValue(a,b,c) ... .Bind(ObsColExtended) incrementaly adding to collection

[LTa2022]

Hi!
I have the following WhenAnyValues, and I cannot figure out how to properly make the second work.

        this.WhenAnyValue(x => x.KeywordVMs).WhereNotNull()
            .Select(x => x.ToObservableChangeSet().AutoRefresh(x => x.IsChecked).Filter(x => x.IsChecked)
            .AsObservableList().Connect()
            .ObserveOn(RxApp.MainThreadScheduler).Bind(CheckedKeywordVMs).Subscribe()).Subscribe();


        this.WhenAnyValue(x => x.KeywordVMs, x => x.KeywordSearch, x => x.TagSearch).Where(x => x.Item1 != null & x.Item2 != null && x.Item3 != null)
            .Select(x => x.Item1.ToObservableChangeSet().AutoRefresh().Filter(kw => kw.Keyword.String.ToLower().Contains(KeywordSearch))
            .AsObservableList().Connect()
            .ObserveOn(RxApp.MainThreadScheduler).Bind(FilteredKeywordVMs).Subscribe()).Subscribe();

Collections are:
[Reactive]
public ObservableCollectionExtended KeywordVMs { get; set; } = new();
[Reactive]
public ObservableCollectionExtended KeywordVMs { get; set; } = new();
[Reactive]
public ObservableCollectionExtended FilteredKeywordVMs { get; set; } = new();

The first one works just fine, but when using a tuple in whenanyvalue, the FilteredKeywordVMs get's added the items incrementaly instead of being the filtered version of the collection.
I just can't find the answer, tried using Distinct and DistinctValues and other changes but couldn't make it work.
Is this (if fixed) a valid approach to have a filtered collection which you can use in another WhenAnyValue with e.g. autorefresh and also bind it to the View?

Thank you, this library changed everything : )!

[LTa2022]

I solved my bindings by splitting up the observables, and also i missed AutoRefreshOnObservable, heres an example:

      var wav_paging = this.WhenAnyValue( x => x.Settings.PerPage, x => x.Settings.CurrentPage);


      var wav_filters = this.WhenAnyValue(x => x.Settings.IncludePublished, x => x.Settings.Search, x => x.ShowForReview);


      pagereq = new PageRequest(0, 2);
      pageSizeRequest = new BehaviorSubject<IPageRequest>(pagereq);

      wav_filters.Subscribe();


      var last_filtered_vms = AppVM.us.Creations.ToObservableChangeSet().AutoRefreshOnObservable(_ => wav_filters).AutoRefresh(x => x.Listing).Sort(SortExpressionComparer<CreationModel>.Descending(x => AppVM.us.Creations.IndexOf(x)))
          .Filter(x =>
             {
                  if (Settings.Search.Trim() != "")
                 {
                     return CreationLikeSearch(x);
                 }
                 if (ShowForReview)
                 {
                     return x.MarkedForReview;
                 }
                 var res = CreationLikeSearch(x) && CreationIsDraft(x);
                 if (res)
                 {

                 }
                 return res;
             }).Page(pageSizeRequest).Select(x => x).Transform(x => new CreationViewModel(x));
      // include sort and virtualize ///// .Reverse().Skip(Settings.PerPage * (Settings.CurrentPage - 1)).Take(Settings.PerPage)


      last_filtered_vms.Bind(out FilteredCreations).Subscribe();


      wav_paging
          .Do(x =>
          {
                  pageSizeRequest.OnNext(new PageRequest(Settings.CurrentPage, Settings.PerPage));
          })
          .Do(x =>
          {
              MaxPage = (int)Math.Ceiling((double)App.VM.us.Creations.Count() / (double)Settings.PerPage);

              if (FilteredCreations?.Count() == 1)
                  SelectedCreation = FilteredCreations.First();
          })
      .Subscribe();

[LTa2022]

2nd comment