使用Rx.Net的搜索实现

Question

我正在C#中使用Rx创建一个搜索页面实现。我创建了一个通用的搜索方法来搜索关键字并在UI上添加结果列表。以下是代码：

通用搜索方法：

   public static IObservable<TResult> GetSearchObservable<TInput, TResult>(INotifyPropertyChanged propertyChanged,
                string propertyName, TInput propertyValue, Func<TInput, TResult> searchFunc)
            {
                // Text change event stream
                var searchTextChanged = Observable.FromEventPattern<PropertyChangedEventHandler, PropertyChangedEventArgs>(
                                                  ev => propertyChanged.PropertyChanged += ev,
                                                  ev => propertyChanged.PropertyChanged -= ev
                                                  )
                                                  .Where(ev => ev.EventArgs.PropertyName == propertyName);
                // Transform the event stream into a stream of strings (the input values)
                var inputStringStream = searchTextChanged.Throttle(TimeSpan.FromMilliseconds(500))
                                                         .Select(arg => propertyValue);
                // Setup an Observer for the search operation
                var search = Observable.ToAsync<TInput, TResult>(searchFunc);
                // Chain the input event stream and the search stream, cancelling searches when input is received
                var results = from searchTerm in inputStringStream
                              from result in search(propertyValue).TakeUntil(inputStringStream)
                              select result;
                return results;
            }

搜索通用方法的用法：

  var rand = new Random();
            SearchObservable.GetSearchObservable<string, string>(this, "SearchString", SearchString, search =>
            {
                Task.WaitAll(Task.Delay(500));
                return SearchString;
            })
            .ObserveOnDispatcher()
            .Subscribe(rese => 
            {
                LstItems.Clear();
                LstItems.Add(SearchString);
                // Heavy operation lots of item to add to UI
                for(int i = 0; i < 200000; i++)
                {
                    LstItems.Add(rand.Next(100, 100000).ToString());
                }
                Result = rese;
            });

这段代码中有两个问题需要帮助来解决：

1. 在泛型方法行from result in search(propertyValue).TakeUntil(inputStringStream)中传递的搜索关键字的值始终为null，因为propertyValue是字符串类型，因此作为值传递到方法中。如何在搜索方法中发送更新后的值？

2. 当在Subscribe方法上执行繁重的UI操作时，如添加大量随机数的示例。当重复执行搜索时，这会导致问题。最终UI会阻塞。我该怎么解决这个问题？

对于第二点，是否有任何方法可以取消以前的UI操作并运行新的操作。这只是一个想法。但需要一些建议来解决这些问题。

Answer 1

1. 您可以传递一个读取属性值的函数，即您的方法应该接受Func<TInput> propertyValueGetter而不是TInput propertyValue

您也可以使用ReactiveUI库。在这种情况下，您的代码看起来像这样：

this.WhenAnyValue(vm => vm.SearchString)
    .Throttle(TimeSpan.FromMilliseconds(500))
    .InvokeCommand(DoSearchString);
DoSearchString = ReactiveCommand.CreateAsyncTask(_ => {
   return searchService.Search(SearchString);
});
DoSearchString.ObserveOn(RxApp.MainThreadScheduler)
              .Subscribe(result => {
                  LstItems.Add(result);
              })

2. 我不相信这个问题有一个普遍的答案。只要在TaskPool上尽可能多地执行操作，当数据准备好显示时，就可以使用ObserveOn切换到UI线程。在您的情况下，您可能会分批插入项目，而不是一次全部插入