RX 스로틀

Question

나는이 코드가 내 컨트롤 내부

(A 자동 완성 컨트롤을하려고) 내 템플릿 기반 컨트롤에서 스레드 동기화 몇 가지 문제가 있습니다

protected override void OnApplyTemplate() 
    { 
     base.OnApplyTemplate(); 

     var searchTextBox = GetTemplateChild("SearchTextBox") as TextBox; 
     if (searchTextBox != null) 
     { 
      var searchDelegate = SearchAsync; 

      Observable.FromEventPattern(searchTextBox, "TextChanged") 
       .Select(keyup => searchTextBox.Text) 
       .Where(TextIsLongEnough) 
       .Throttle(TimeSpan.FromMilliseconds(500)) 
       .Do(ShowProgressBar) 
       .SelectMany(searchDelegate) 
       .ObserveOn(Dispatcher) 
       .Subscribe(async results => await RunOnDispatcher(() => 
                     { 
                      IsInProgress = false; 
                      SearchResults.Clear(); 
                      foreach (var result in results) 
                      { 
                       SearchResults.Add(result); 
                      } 
                     })); 
     } 
    } 

을 그리고 그것은 불평 내 ShowProgressBar 메서드 내에서 다른 스레드에 의해 마샬링 된 코드에 액세스하려고합니다.

Throttle과 ObserveOn (Dispatcher)을 주석 처리하면 정상적으로 작동하지만 원하는대로 내 서비스 호출을 차단하지 않습니다.

스로틀 부분 만 주석 처리하면 아무 일도 일어나지 않습니다.

Answer 1

아 스티의 .Do(() => Dispatcher.Invoke(new Action(ShowProgressBar))) 오른쪽 아이디어를 얻었으나, 훨씬 더 좋은 방법은 대신 스로틀 링하는 IScheduler 인수를 제공하는 것 ShowMenu까지 ShowProgressBar를 포함하여).

Answer 2

모든 종속성 개체에는 종속성 속성이 변경되면 be made only on the Dispatcher thread이 필요합니다. Throttle은 다른 스케줄러를 사용하므로 이후의 Do 연결자에서 UI를 변경하면 액세스 예외가 발생합니다.

다음과 같은 방법으로이 문제를 해결할 수 있습니다

1. 는 Dispatcher에서 부작용을 일으킬 조치 전에 ObserveOnDispatcher를 추가합니다. 선택적으로 파이프 라인을 따라 다른 스케줄러를 사용하십시오.
2. Dispatcher.Invoke을 사용하여 디스패처를 통해 부작용을 실행합니다. (가 UI 스레드에서 발생 아래
   이

   // NB: Too lazy to look up real name 
   .Throttle(TimeSpan.FromMilliseconds(500), CoreDispatcherScheduler.Instance) 
   

   이 작업을 할 것입니다 : 예,