두 개의 정렬 된 관측 값 간의 관측 값을 만드는 방법은 무엇입니까?

Question

두 개의 정렬 된 복식을 관찰 할 수 있다고 가정 해 보겠습니다. 나는 그들 사이의 차이점을 관찰 할 수있는 것으로보고 싶습니다. 예를 들어이에 대한

  1  2   4   
left: ──o───────o───────────o────/ 
      1 3 4 5 
right: ──o────o──o───o───/ 
        l2   r3 r5 
output: ──────────o───────────o────o─/ 

명령형 구현은 간단하다 : 당신은 여전히 ​​도달하고 다른 측면에서 항목을 "방출"적이 없다 측면에있는 항목의 목록을 유지합니다.

RFP 세계에서 표준 접근 방식은 무엇입니까? 나는 특별히 RxScala를 사용하고 있습니다.

Answer 1

이것은 rxjava에서 두 관측 값의 길이가 같음을 의미합니다.

Observable<Integer> obs1 = Observable.just(1, 2, 4, 6); 
    Observable<Integer> obs2 = Observable.just(1, 3, 4, 5); 

    obs1.zipWith(obs2, (integer, integer2) -> { 
     if (!Objects.equals(integer, integer2)) { 
      return Observable.just(integer).concatWith(Observable.just(integer2)); 
     } else { 
      return Observable.empty(); 
     } 
    }) 
     .flatMap(observable -> observable) 
     .sorted() 
     .forEach(System.out::println); 

편집

또 다른 방법은 모음 내가 그 "실시간"대칭 차이 할 RxJava에서 많이 없다고 생각

Observable<Integer> obs1 = Observable.just(1, 2, 4); 
    Observable<Integer> obs2 = Observable.just(1, 3, 4, 5); 


    obs1.mergeWith(obs2) 
      .sorted() 
      .reduce(new ArrayList<Integer>(), (integers, integer) -> { 
       if (integers.contains(integer)) { 
        integers.remove(integer); 
       } else { 
        integers.add(integer); 
       } 
       return integers; 
      }) 
      .flatMapIterable(integers -> integers) 
      .forEach(System.out::println); 

Answer 2

을 사용하는 것입니다. .. 당신의 시작 가정 (관측 가능한 것들이 정렬 됨)이 일반 연산자들에 의해 만들어 질 수 없기 때문에 주로 당신을 도와 줄 것입니다.

그러나 sequenceEqual에서 영감을 얻어 맞춤형 연산자를 코딩 할 수 있습니다. 즉, 두 게시자간에 단계별로 진행되어 평등 비교를 수행하므로 수행하려는 작업에 가깝습니다.