Buffer PropertyChanged Events

Question

У меня есть приложение wpf со всем наложением видаModel с классом NotifyPropertyChangeClass, реализующим INotifyPropertyChanged (см. Ниже).

Я хочу дросселировать уведомления, отправленные на просмотр, чтобы избежать отставания из-за слишком большого количества отправленных уведомлений. До сих пор я достигаю задержки для каждого свойства с использованием метода Образец реактивного расширения.

Проблема в том, что Gui обновляется поздно с помощью дросселирования. Он будет чувствовать себя более отзывчивым иметь первое событие, которое вызывается при запуске периода, как это:

Кодекса NotifyPropertyChangeClass:

using System; 
using System.ComponentModel; 
using System.Reactive.Linq; 

namespace MyNameSpace 
{ 
    public class NotifyPropertyChangeClass : INotifyPropertyChanged 
    { 
     public NotifyPropertyChangeClass(int throttlingPeriod) 
     { 
      var obs = Observable.FromEventPattern<PropertyChangedEventHandler, PropertyChangedEventArgs>(
       h => this.privatePropertyChanged += h, h => this.privatePropertyChanged -= h); 
      var groupedByName = obs.Select(o => o.EventArgs.PropertyName).GroupBy(x => x).SelectMany(o => o.Sample(TimeSpan.FromMilliseconds(throttlingPeriod))); 
      groupedByName.Subscribe(o => 
      { 
       PropertyChangedEventHandler handler = PropertyChanged; 
       if (handler != null) 
        handler(this, new PropertyChangedEventArgs(o)); 
      }); 
     } 
     public event PropertyChangedEventHandler PropertyChanged; 
     private event PropertyChangedEventHandler privatePropertyChanged; 

     protected virtual void OnPropertyChanged(string propertyName) 
     { 
      PropertyChangedEventHandler handler = privatePropertyChanged; 
      if (handler != null) 
       handler(this, new PropertyChangedEventArgs(propertyName)); 
     } 
    } 
} 

Как я могу добиться того, что я хочу?

Answer 1

Я не пробовал, но вы можете попробовать это:

using System; 
using System.ComponentModel; 
using System.Reactive.Linq; 

namespace MyNameSpace 
{ 
    public class NotifyPropertyChangeClass : INotifyPropertyChanged 
    { 
     private bool _isThrottling = false; 

     public NotifyPropertyChangeClass(int throttlingPeriod) 
     { 
      var obs = Observable.FromEventPattern<PropertyChangedEventHandler, PropertyChangedEventArgs>(
       h => this.privatePropertyChanged += h, h => this.privatePropertyChanged -= h); 
      var groupedByName = obs.Select(o => o.EventArgs.PropertyName).GroupBy(x => x).SelectMany(o => o.Sample(TimeSpan.FromMilliseconds(throttlingPeriod))); 
      groupedByName.Subscribe(o => 
      { 
       PropertyChangedEventHandler handler = PropertyChanged; 
       if (handler != null) 
        handler(this, new PropertyChangedEventArgs(o)); 
       _isThrottling = false; 
      }); 
     } 
     public event PropertyChangedEventHandler PropertyChanged; 
     private event PropertyChangedEventHandler privatePropertyChanged; 

     protected virtual void OnPropertyChanged(string propertyName) 
     { 
      // Will fire the first time, the event is raised 
      if (!_isThrottling) 
      { 
       PropertyChangedEventHandler handler = PropertyChanged; 
       if (handler != null) 
        handler(this, new PropertyChangedEventArgs(o)); 
      } 

      // Setting to true here will suppress raising the public event 
      // for every subsequent call, until the event is raised 
      // by the observable pattern and the flag is set to false again. 
      _isThrottling = true; 

      // Will always be raised 
      PropertyChangedEventHandler handler = privatePropertyChanged; 
      if (handler != null) 
       handler(this, new PropertyChangedEventArgs(propertyName)); 
     } 
    } 
}