2

当用户在文本框中输入内容时，我必须ReactiveAsyncCommand执行搜索，该文本框的设置如下：

var results = SearchCommand.RegisterAsyncFunction(term => 
PerformSearch((string)term));

this.ObservableForProperty(x => x.SearchTerm)
.Throttle(TimeSpan.FromMilliseconds(800))
.Select(x => x.Value).DistinctUntilChanged()
.Where(x => !String.IsNullOrWhiteSpace(x))
.InvokeCommand(SearchCommand);

_SearchResults = results.ToProperty(this, x => x.SearchResults);

问题是搜索功能可能会很慢，因为它需要执行数据库查询并显示过时的结果，我认为这是由于ReactiveAsyncCommand在当前异步任务完成之前没有再次运行。

所以我的问题是，我怎样才能取消正在运行的异步任务并从当前搜索词重新开始，或者如果它不是当前搜索词，则完全删除结果。

这似乎与本讨论的第二部分相同，但我不确定如何将其应用于我的代码，因为我的搜索代码返回的是 IEnumerable 而不是 IObservable。

请注意 RxUI 4 的这一点，因为它是一个 .NET 4 应用程序。

更新：PerformSearch 方法

private List<WizardLocationSearchResult> PerformSearch(string searchTerm)
{
var results = new List<WizardLocationSearchResult>();
bool isMatch = false;


if (Regex.IsMatch(searchTerm, _postcodeRegex, RegexOptions.IgnoreCase))
{
    var locationResult = _locationService.GetByPostcode(searchTerm);
    _locationService.DeepLoad(locationResult, true, Data.DeepLoadType.IncludeChildren, typeof(TList<EnterpriseAndHolding>));

    results.AddRange(ProcessLocationSearches(locationResult));
    isMatch = true;
}


if (!isMatch)
{
    var query = new LocationParameterBuilder(true, false);
    string formattedSearchTerm = searchTerm + "%";
    query.AppendLike(LocationColumn.Address1, formattedSearchTerm);
    query.AppendLike(LocationColumn.Address2, formattedSearchTerm);
    query.AppendLike(LocationColumn.Town, formattedSearchTerm);
    query.AppendLike(LocationColumn.PostalTown, formattedSearchTerm);
    query.AppendLike(LocationColumn.County, formattedSearchTerm);

    var locationResult = _locationService.Find(query.GetParameters());
    _locationService.DeepLoad(locationResult, true, Data.DeepLoadType.IncludeChildren, typeof(TList<EnterpriseAndHolding>));
    results.AddRange(ProcessLocationSearches(locationResult));
}

return results;
}
4

1 回答 1

1

背后的想法ReactiveAsyncCommand是它有意限制进行中请求的数量。在这种情况下，您想忘记该约束，因此让我们使用常规ReactiveCommand代替：

SearchCommand
    .Select(x => Observable.Start(() => PerformSearch(x), RxApp.TaskPoolScheduler))
    .Switch()
    .ToProperty(this, x => x.SearchResults);

请注意，Select.Switch这里与 类似SelectMany，只是它将始终保持输入的顺序，同时在旧输入未及时完成时丢弃它们。

废话 CancellationTokenSource 废话 TPL

_locationService.DeepLoad在这种情况下，底层方法本身（这里。

编辑：这是一个丑陋的黑客来确定物品是否在飞行中：

SearchCommand
    .Do(x => Interlocked.Increment(ref searchesInFlight))
    .Select(x => Observable.Start(() => PerformSearch(x), RxApp.TaskPoolScheduler).Do(x => Interlocked.Decrement(ref searchesInFlight)))
    .Switch()        
    .ToProperty(this, x => x.SearchResults);
于 2013-08-02T07:42:15.017 回答