IEnumerable<Step> EventsAnalytic(TaskPull pull, Queue<Event> events, Form form)
{
  SlyFilter filter = new SlyFilter(events);
  
  while (true)
  {
    Event event = filter.Filter();
    if (event != null)
    {
      Task task = pull.StartTask(ThreadLabel.Server, ServerSend(event));
      yield return new WaitStep(delegate
        {
          return task.IsCompleted || events.Count != 0;
        });

      if (task.IsCompleted)
      {
        ServerResult result = task.Finish<ServerResult>();
        // Изменяем UI
        form.Text = result.Title;
      }
    }
    else
    {
      yield return new WaitStep();
    }
  }
}

void Main()
{
  // Запускаем анализатор событий в главном потоке
  pull.StartTask(ThreadLabel.Main, EventAnalytic(pull, events, form);
}

if (!task.IsCompleted)
  pull.StartTask(CancelServerQuery());

WH> То что ты не умеешь его готовить не значит что его готовить невозможно.

    var txt = new TextBox(); 
    var lst = new ListBox { Top = txt.Height + 10 }; 
    var frm = new Form { 
        Controls = { txt, lst } 
    }; 
 
    // Turn the user input into a tamed sequence of strings. 
    var textChanged = from evt in Observable.FromEvent<EventArgs>(txt, "TextChanged") 
                      select ((TextBox)evt.Sender).Text; 
 
    var input = textChanged 
                .Throttle(TimeSpan.FromSeconds(1)) 
                .DistinctUntilChanged(); 
 
    // Bridge with the web service's MatchInDict method. 
    var svc = new DictServiceSoapClient("DictServiceSoap"); 
    var matchInDict = Observable.FromAsyncPattern<string, string, string, DictionaryWord[]> 
        (svc.BeginMatchInDict, svc.EndMatchInDict); 
 
    Func<string, IObservable<DictionaryWord[]>> matchInWordNetByPrefix = 
        term => matchInDict("wn", term, "prefix"); 
 
    // The grand composition connecting the user input with the web service. 
    var res = from term in input 
              from word in matchInWordNetByPrefix(term).TakeUntil(input) 
              select word; 
 
    // Synchronize with the UI thread and populate the ListBox or signal an error. 
    using (res.ObserveOn(lst).Subscribe( 
        words => { 
            lst.Items.Clear(); 
            lst.Items.AddRange((from word in words select word.Word).ToArray()); 
        }, 
        ex => { 
            MessageBox.Show("An error occurred: " + ex.Message, frm.Text, 
                            MessageBoxButtons.OK, MessageBoxIcon.Error); 
        })) 
    { 
        Application.Run(frm); 
    } // Proper disposal happens upon exiting the application.

WH>Можно принципиально проще.

    var textChanged = from evt in Observable.FromEvent<EventArgs>(txt, "TextChanged") 
                      select ((TextBox)evt.Sender).Text;

IEnumerable<Step> EventsAnalytic(TaskPull pull, Form form)
{
  // Получаем ссылку на таску и на поток, в котором она запущена
  StateStep stateStep = new StateStep();
  yield return stateStep;

  SlyFilter filter = new SlyFilter(events, TimeSpan.FromSeconds(1));

  Queue<Event> events = new Queue<Event>();
  form.txt.TextChanged += delegate
  {
    events.Enqueue(new Event());
    // Инициируем внеочередный вызов таски
    stateStep.Force();
  };
  
  while (true)
  {
    Event event = filter.Filter();
    if (event != null)
    {
      Task task = pull.StartTask(ThreadLabel.Server, ServerSend(stateStep, event));
      // Указываем допустимое время ожидания и задаем, что поток должен инициировать вызов таски по истечению времени таймаута
      yield return new WaitStep(timeout, timeout, delegate
        {
          return task.IsCompleted || events.Count != 0;
        });

      if (task.IsCompleted)
      {
        ServerResult result = task.Finish<ServerResult>();
        // Изменяем UI
        form.lst.Items.Clear();
        form.lst.Items.AddRange(result.Items);
      }
    }

    if (events.Count != 0)
      yield return new WaitStep(TimeSpan.FromSeconds(1));
    else
      yield return new WaitStep(TimeSpan.FromHours(1));
  }
}

void Main()
{
  // Запускаем анализатор событий в главном потоке
  pull.StartUITask(EventsAnalytic(pull, form);
}

WH>А это уже пуш

WH>Переписывание кода в конечный автомат это конечно очень просто.

U>    var textChanged = from evt in Observable.FromEvent<EventArgs>(txt, "TextChanged") 
U>                      select ((TextBox)evt.Sender).Text; 
U>

select txt.Text;

txt.TextChanged += (s, a) => { DoSomethingWith(txt.Text); }

    var input = textChanged 
                .Throttle(TimeSpan.FromSeconds(1)) 
                .DistinctUntilChanged();