는 UI 스레드에서 호출 UI 스레드

Question

이 코드에 메시지를 전달하는 관찰 가능한 타이머를 필요 :

public void ShowProgress(Action<long> notify, Action terminate) 
{ 
    this.Progress = Observable.Timer(ProgressInterval, ProgressInterval).Finally(terminate).Subscribe(notify); 
} 

블록 UI 스레드 완전히는 응답 만들기 : ShowProgress가하는

Jobs.Current.ShowProgress(_ => 
    { 
     if (Jobs.Current.Duration == 0 && this.progressBarMarkJob.Value >= this.progressBarMarkJob.Maximum - this.progressBarMarkJob.Step/2) 
     { 
      this.progressBarMarkJob.Step /= 2; 
     } 
     this.progressBarMarkJob.PerformStep(); 
    },() => 
    { 
     stopwatch.Stop(); 
     var elapsed = string.Format(stopwatch.Elapsed.TotalHours >= 1 ? @"{0:hh\:mm\:SS}" : @"{0:mm\:SS}", stopwatch.Elapsed); 
     this.labelMarkTime.Text = string.Format("Elapsed{0:8}", elapsed); 
     this.labelMarkTime.Visible = true; 
     Jobs.Current.Duration = (uint)stopwatch.Elapsed.TotalSeconds; 
     this.progressBarMarkJob.Value = this.progressBarMarkJob.Maximum; 
    }); 

.

Subscribe() 호출 전에 .SubscribeOn (Scheduler.CurrentThread)을 삽입하면 더 이상 UI 스레드가 차단되지 않습니다. 그러나 메시지가 올바른 스레드의 UI로 전달되지 않기 때문에 교차 스레드 예외가 발생합니다.

타이머에서 업데이트를 가져올 수 있도록 UI가 응답하도록 - UI 스레드에 다시 게시되도록 작업 할 수있는 방법이 있습니까?

Answer 1

ObserveOn()에 전화를 추가해야합니다. 당신이 패키지 RX-XAML을 nuget 사용하는 경우) (ObserveOnDispatcher을 활용할 수 있습니다

this.Progress = Observable.Interval(ProgressInterval) 
          .ObserveOnDispatcher() 
          .Finally(terminate) 
          .Subscribe(notify); 

See my answer here to understand the difference between ObserveOn and SubscribeOn합니다. 또한 PerformStep()에 대한 코드를 제공하지 않습니다. 빠른 속도 및/또는 비 차단 기능이 있기를 바랍니다.

또한 Timer을 Interval으로 바꾸 었으므로 인수가 저장됩니다.

마지막으로 작업 완료시 구독 핸들 (this.Progress)을 삭제할 계획입니까?