RXJava - 나는 두 개의 관찰 가능한을 결합하려는

Question

어떤 결과를 잃지 않고 combineLatest, 하나는 n 개의 항목을 모두 관찰 가능한 적어도 하나 개의 항목을 방출 할 때까지 단 1

combineLatest가 대기하는 다른 하나를 방출 한 후 최신이 방출 결합 관찰 할 수있을 때까지 항목을 연대순으로 다음과 같은 고려 주문 :

• 관찰 가능한 A는 ->는 결과 A1을 방출
• 관찰 가능한 A -> 결과 A2를 방출
• 관찰 가능한 B ->은 결과 B1은

는 combineLatest은 결과 (2)를 결합합니다

방출 관찰 가능한 1의 결과 1과 관찰 가능한 2의 결과 1 (여기서 쉽게 테스터가 될 수 있음 : http://rxmarbles.com/#combineLatest).

내가

필요 내가 상관없이 하나가 빠르게하는 두 개의 관찰 가능한의 모든 항목을 결합하지해야합니다. 어떻게해야합니까?

결과 (독립있는 관찰 개시 먼저 상품 발광 항상!) 같아야

• A1이 B1과

Answer 1

참고 결합

A2이 안된 B1 결합 :

을

관찰 가능 시퀀스 a에서 ReplaySubject을 만듭니다. 시퀀스 b에서 방출하는 각 값에 대해 해당 값을 재생 제목과 결합하여 Pair<A, B>이라는 새로운 관찰 가능 항목을 만듭니다. 평면 관측치를 함께 매핑하고 그 결과로 반환합니다.

public static <A, B> Observable<Pair<A, B>> permutation(
    Observable<A> observableA, 
    Observable<B> observableB, 
) { 
    ReplaySubject<A> subjectA = ReplaySubject.create(); 
    observableA.subscribe(subjectA::onNext); 
    return observableB.flatMap(b -> subjectA.map(a -> Pair.of(a, b))); 
}