使用 ReactiveUI 和 Caliburn.Micro 分页列表框

Question

我正在尝试使用 Caliburn.Micro.ReactiveUI 并使用“.Skip(currentPage).Take(pageSize)”调用 EF 来实现列表框的分页机制。一般来说，我是 ReactiveUI 和 Reactive 的新手。我相信这应该很容易。

我有一个 "SearchParameters" class 需要观察，并且当 SearchParameters 对象的任何属性发生变化时需要执行搜索函数。

您可以从注释掉的代码中看出，我也尝试将 class 定义为 ReactiveObject。目前的实现是使用 CM 的 PropertyChangedBase。在我看来，各个属性是使用 CM 约定的绑定文本框：

public class SearchParameters : PropertyChangedBase
    {

        private string _searchTerm;
        public string SearchTerm
        {
            get { return _searchTerm; }
            set
            {
                if (value == _searchTerm) return;
                _searchTerm = value;
                NotifyOfPropertyChange(() => SearchTerm);

            }
        }
        private int _pageSize;
        public int PageSize
        {
            get { return _pageSize; }
            set
            {
                if (value == _pageSize) return;
                _pageSize = value;
                NotifyOfPropertyChange(() => PageSize);

            }
        }

        private int _skipCount;
        public int SkipCount
        {
            get { return _skipCount; }
            set
            {
                if (value == _skipCount) return;
                _skipCount = value;
                NotifyOfPropertyChange(() => SkipCount);

            }
        }

        //private string _searchTerm;
        //public string SearchTerm
        //{
        //    get { return _searchTerm; }
        //    set { this.RaiseAndSetIfChanged(ref _searchTerm, value); }
        //}
        //private int _pageSize;
        //public int PageSize
        //{
        //    get { return _pageSize; }
        //    set { this.RaiseAndSetIfChanged(ref _pageSize, value); }
        //}

        //private int _skipCount;
        //public int SkipCount
        //{
        //    get { return _skipCount; }
        //    set { this.RaiseAndSetIfChanged(ref _skipCount, value); }
        //}

    }

"SearchService" 有以下方法需要在 SearchParameter 的任何一个值发生变化时执行：

public async Task<SearchResult> SearchAsync(SearchParameters searchParameters)
    {
        return await Task.Run(() =>
        {
            var query = (from m in _hrEntities.Departments select m);
            if (!String.IsNullOrEmpty(searchParameters.SearchTerm))
            {
                searchParameters.SearchTerm = searchParameters.SearchTerm.Trim();
                query = query.Where(
                    x => x.Employee.LastName.Contains(searchParameters.SearchTerm) || x.Employee.FirstName.Contains(searchParameters.SearchTerm)).Skip(searchParameters.SkipCount).Take(searchParameters.PageSize);
            }
            return new SearchResult
            {
                SearchTerm = searchParameters.SearchTerm,
                Matches = new BindableCollection<DepartmentViewModel>(query.Select(x => new DepartmentViewModel{ Department = x }).Skip(searchParameters.SkipCount).Take(searchParameters.PageSize))
            };
        });
    }

以下是我尝试将所有这些连接到 MainViewModel 的 ctor 以及 Rx 对我来说变得模糊的地方：

public class MainViewModel : ReactiveScreen
{
private SearchParameters _searchParameters;
        public SearchParameters SearchParameters
        {
            get { return _searchParameters; }
            set
            {
                if (value == _searchParameters) return;
                _searchParameters = value;
                NotifyOfPropertyChange(() => SearchParameters);
            }
        }
{

public void MainViewModel()
{
    var searchService = new SearchService();
    //default Skip and PageSize values
    SearchParameters = new Services.SearchParameters { SkipCount = 0 , PageSize = 10};

    var searchParameters = this.ObservableForProperty(x => x.SearchParameters)
                .Value()
                .Throttle(TimeSpan.FromSeconds(.3));
    var searchResults = searchParameters.SelectMany(parameters => searchService.SearchAsync(parameters));
            var latestMatches = searchParameters
               .CombineLatest(searchResults,    
                   (searchParameter, searchResult) =>
                       searchResult.SearchTerm != searchParameter.SearchTerm
                           ? null
                           : searchResult.Matches)
               .Where(matches => matches != null);
    _departmentViewModels = latestMatches.ToProperty(this, x => x.DepartmentViewModels);
            searchParameters.Subscribe(x => Debug.WriteLine(x));
}
}

在上面的示例中，对 SearchAsync 的调用没有执行。似乎没有观察到对 SearchParameter 属性的更改。

谁能告诉我我做错了什么？

Answer 1

尽管有人提出建议，我很想听听其他解决方案，但我最终是这样做的。我不确定这是否是最好的方法，但它有效：

首先，我在我的 SearchParameters class 中定义了一个计算的属性 returns 一个字符串，并在任何时候从视图更新 CurrentPage、SkipCount 和 PageSize 时重新评估：

public string ParameterString
        {
            get { return String.Format("SearchTerm={0}|SkipCount={1}|PageSize={2}", SearchTerm, SkipCount, PageSize); }
        }

接下来，在我的 MainViewModel ctor 中，我只是观察计算结果，而不是尝试分别对 SearchTerm、SkipCount 和 PageSize 做出反应（我最初的问题是询问如何做）：

var searchTerms = this
                .ObservableForProperty(x => x.SearchParameters.ParameterString)
                .Value()
                .Throttle(TimeSpan.FromSeconds(.3));

var searchResults = searchTerms.SelectMany(parameters => SearchService.SearchAsync(parameters));
            var latestMatches = searchTerms
               .CombineLatest(searchResults,
                   (searchTerm, searchResult) =>
                       searchResult.SearchTerm != searchTerm
                           ? null
                           : searchResult.Matches)
               .Where(matches => matches != null);

最后，在我的 SearchService 中，我解析参数字符串以获取当前值：

var parameters = searchParameters.Split('|');
            var searchTerm = "";
            var skipCount = 0;
            var pageSize = 0;
            foreach (var parameter in parameters)
            {
                if (parameter.Contains("SearchTerm="))
                {searchTerm = parameter.Replace("SearchTerm=", "");}
                else if (parameter.Contains("SkipCount="))
                { skipCount = Convert.ToInt32(parameter.Replace("SkipCount=", "")); }
                else if (parameter.Contains("PageSize="))
                { pageSize = Convert.ToInt32(parameter.Replace("PageSize=", "")); }
            }

使用 ReactiveUI 和 Caliburn.Micro 分页列表框

Paging ListBox with ReactiveUI and Caliburn.Micro

wpf

reactiveui

caliburn.micro.reactiveui