반응 확장 기능을 위해 겹치는 스트림을 처리하는 방법은 무엇입니까? <code>A - B - C</code>가 순차적으로 발생하면</p> <p>1) :</p> <pre><code>X - X - A - B - C - X - X </code></pre> <p>내가이 사건에 관심이 :

Question

내가이 같은 일련의가 있다고 가정.

2-) B - C이 순차적으로 발생하고 A - B - C이 발생하지 않는 경우.

따라서 구독하겠습니다. 예를 들어

A - B - CX - B - C이 발생하면 그때 BC 인쇄하는 반면 I은 단지 ABC 아니지만 BC를 인쇄 할 경우에 발생한다. 어떻게해야합니까?

Answer 1

소스가 IObservable<char> 다음이 시도하는 경우 :

IObservable<string> query1 = 
    source 
     .Publish(ss => 
      ss 
       .Zip(ss.Skip(1), (s0, s1) => new { s0, s1 }) 
       .Zip(ss.Skip(2), (s01, s2) => new { s01.s0, s01.s1, s2 })) 
     .Where(s => s.s0 == 'A' && s.s1 == 'B' & s.s2 == 'C') 
     .Select(s => String.Join("", s.s0, s.s1, s.s2)); 

IObservable<string> query2 = 
    source 
     .Publish(ss => 
      ss 
       .Zip(ss.Skip(1), (s0, s1) => new { s0, s1 }) 
       .Zip(ss.Skip(2), (s01, s2) => new { s01.s0, s01.s1, s2 })) 
     .Where(s => s.s0 != 'A' && s.s1 == 'B' & s.s2 == 'C') 
     .Select(s => String.Join("", s.s1, s.s2));