하는 다른 유형의 두 가지 소스를 결합하는 방법을

Question

는 설정 :

• 먼저 IObservable 유형 의 값을 생성하는
• 둘째 IObservable 유형 B 그들은 생산
• 의 값을 생성 각기 다른 속도의 가치 (매우 빠른, 매 10ms마다)

내가 달성하기 위해 노력하고 무엇

:

모든 N 시간 통화가 모두 먼저 및 두 번째에서 최신 값을 서비스에 수행하고 제공해야한다 (N은 매우 느린 약 500 밀리)IObservable.

질문 : RX를 사용하여 어떻게 할 수 있을지 궁금합니다.

현재 솔루션 (비 작동) :

var stateObs = from drag in dragObs.MostRecent(0).ToObservable() 
       from roll in rollObs.MostRecent(0).ToObservable() 
       select new ClientState 
          { 
           FileDragPerc = drag, 
           PhoneRoll = roll, 
           PendingFileType = FileType.Image, 
           TransferState = TransferState.SelectiveTransfer 
          }; 

stateObs.Sample(TimeSpan.FromMilliseconds(300)) 
     .Subscribe(x => _lsService.SetClientStateAsync(x), 
        x => Debug.WriteLine("Error in observable "), 
        () => Debug.WriteLine("Error observable finished! ")); 

Answer 1

정확합니다. 즉 CombineLatest 운전자가 무엇이다 : 어느 시퀀스의 마지막 값은 한 쌍의 절환 동작을 생성하는 유지

A: 1...2...3...4...5... 

B: a.....b.........c... 

. 출력 스트림은 (1,a) (2,a) (2,b) (3,b) 등이됩니다.

스트림에서 적절한 쌍을 구성해야하는 경우 'Zip'연산자를 사용하면 (1,a) (2,b) (3,c) 등이 표시됩니다.

P.

필자는 컴파일러가 쿼리 이해를 다시 작성하는 방법을 더 잘 이해하려고 시도 할 것을 제안합니다. 그것은 당신의 혼란의 대부분을 해결할 것입니다.

from a in oA 
from b in oB 
select ... 

효과적으로 SelectMany(oA, oB)

Answer 2

내가 답을 찾은 것 같아 자신

CombineLatest() 작업은 그냥 이 그래서 내가 무엇을 얻을 필요한 작업 :

var stateObs = dragObs.CombineLatest(rollObs, (d, r) => new ClientState 
                 { 
                  FileDragPerc = d, 
                  PhoneRoll = r, 
                  TransferState = TransferState.SelectiveTransfer, 
                  PendingFileType = FileType.Image 
                 }); 

    stateObs.Sample(TimeSpan.FromMilliseconds(300)) 
      .Subscribe(x => _lsService.SetClientStateAsync(x), 
         x => Debug.WriteLine("Error in observable "), 
         () => Debug.WriteLine("Error observable finished! "));