Подождите, пока не произойдет такое же событие в течение промежутка времени, используя Rx

Question

Использование Reactive.NET, как я могу подождать, пока одно и то же событие не произойдет за n секунд до выполнения действия?

Следующий пример (C#, WinForms) делает то, что я хочу, но я хочу задержку (скажем 1 секунду) перед расширяющейся происходит:

var autoExpand = Observable.FromEventPattern<DragEventArgs>(tree, "DragOver"); 

autoExpand 
    .ObserveOn(SynchronizationContext.Current) 
    .Distinct(dragEvent => tree.GetNodeFromCoordinates(dragEvent.EventArgs.X, dragEvent.EventArgs.Y)) 
    .Subscribe(dragEvent => { 
      TreeNode node = tree.GetNodeFromCoordinates(dragEvent.EventArgs.X, dragEvent.EventArgs.Y); 

      if (node != null) node.Expand(); 
     }); 

Answer 1

Я считаю, что вы ищете Throttle:

var autoExpand = Observable.FromEventPattern<DragEventArgs>(tree, "DragOver"); 

autoExpand 
    .Select(dragEvent => tree.GetNodeFromCoordinates(dragEvent.EventArgs.X, dragEvent.EventArgs.Y)) 
    .DistinctUntilChanged() 
    .Throttle(TimeSpan.FromSeconds(1)) 
    .ObserveOn(SynchronizationContext.Current) 
    .Subscribe(node => { 
      if (node != null) node.Expand(); 
     }); 

Примечание:

• Чтобы избежать tree.GetNodeFromCoordinates() дважды, я использовал его с Select оператора довести ее до подписки
• Удобных, мы можем использовать DistinctUntilChanged блокировать повторяющиеся события выбора узла, если узел является тот же
• я переехал оператор ObserveOn к после Throttle вызова, чтобы избежать блокировок нити - общие рекомендации для ObserveOn предполагают, что вы должны оставить его последним оператором перед подпиской. Если вам нужно использовать SynchronizationContext.Current для tree.GetNodeFromCoordinates(), вам может понадобиться несколько раз переключать планировщики, чтобы избежать исключений перекрестных потоков.