Вы должны использовать Microsoft Reactive Framework (он же Rx) - NuGet System.Reactive.Windows.Threading
и добавить using System.Reactive; using System.Reactive.Linq;
- тогда вы можете сделать что-то удивительное.
Я смоделировал немного кода, похожего на ваш.Я начал с TextBox
и TextBlock
и фиктивного метода для выполнения поиска:
private async Task<string> PerformSearchAsync(string text)
{
await Task.Delay(TimeSpan.FromSeconds(2.0));
return "Hello " + text;
}
Теперь в конструкторе после this.InitializeComponent();
я создал следующую наблюдаемую, которая реагирует на всеTextChanged
события на моем textBox1
:
IObservable<EventPattern<TextChangedEventArgs>> textChanges =
Observable
.FromEventPattern<TextChangedEventHandler, TextChangedEventArgs>(
h => textBox1.TextChanged += h,
h => textBox1.TextChanged -= h);
Затем я написал запрос для ответа на изменения текста:
IObservable<string> query =
textChanges
.Select(x =>
Observable
.FromAsync(() => PerformSearchAsync(textBox1.Text))
.StartWith("Searching..."))
.Switch();
По сути, это ожидание каждого изменения текста и инициацияасинхронный вызов PerformSearchAsync
, который возвращает результаты поиска в виде строки, а также сразу возвращает строку "Searching..."
..Switch()
используется, чтобы убедиться, что только последний вызов PerformSearchAsync
действительно возвращает результат.
Теперь я могу просто наблюдать запрос:
_subscription =
query
.ObserveOnDispatcher()
.Subscribe(x => textBlock1.Text = x);
Переменная _subscription
определяется как private IDisposable _subscription = null;
.Он используется для того, чтобы я мог позвонить _subscription.Dispose()
, чтобы безопасно закрыть подписку.
Он ведет себя так, как вы хотите.
Весь мой код выглядит так:
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Reactive;
using System.Reactive.Linq;
using System.Runtime.InteropServices.WindowsRuntime;
using System.Threading.Tasks;
using Windows.Foundation;
using Windows.Foundation.Collections;
using Windows.UI.Xaml;
using Windows.UI.Xaml.Controls;
using Windows.UI.Xaml.Controls.Primitives;
using Windows.UI.Xaml.Data;
using Windows.UI.Xaml.Input;
using Windows.UI.Xaml.Media;
using Windows.UI.Xaml.Navigation;
namespace App5
{
/// <summary>
/// An empty page that can be used on its own or navigated to within a Frame.
/// </summary>
public sealed partial class MainPage : Page
{
private IDisposable _subscription = null;
public MainPage()
{
this.InitializeComponent();
IObservable<EventPattern<TextChangedEventArgs>> textChanges =
Observable
.FromEventPattern<TextChangedEventHandler, TextChangedEventArgs>(
h => textBox1.TextChanged += h,
h => textBox1.TextChanged -= h);
IObservable<string> query =
textChanges
.Select(x =>
Observable
.FromAsync(() => PerformSearchAsync(textBox1.Text))
.StartWith("Searching..."))
.Switch();
_subscription =
query
.ObserveOnDispatcher()
.Subscribe(x => textBlock1.Text = x);
}
private async Task<string> PerformSearchAsync(string text)
{
await Task.Delay(TimeSpan.FromSeconds(2.0));
return "Hello " + text;
}
}
}
Вы должны быть в состоянии приспособить это для работы с вашим кодом.