RXJava - combineLatest ohne Ergebnis zu verlieren

Question

ich zwei Observablen kombinieren möchten, gibt man n Elemente und die andere nur 1.

combineLatest warten, bis beide Observablen haben mindestens ein Element emittiert wird, und kombiniert dann die neuesten emittiert Gegenstände, bis beide beobachtbar sind. Betrachten wir folgende chronologisch bestellen:

• Observable A -> emittiert A1 Ergebnis
• Observable A -> emittiert A2 Ergebnis
• Observable B -> emittiert Ergebnis B1

combineLatest nur Ergebnis kombinieren 2 von beobachtbaren 1 mit Ergebnis 1 von beobachtbaren 2 (kann hier leicht tester sein: http://rxmarbles.com/#combineLatest).

Was ich

brauche ich, um alle Elemente von zwei Observablen zu kombinieren, egal welche schneller ist. Wie kann ich das machen?

Ergebnis soll (immer, unabhängig davon, welche beobachtbaren beginnen Artikel zuerst emittierende!) Sein:

• A1 in Kombination mit B1
• A2 mit B1 kombiniert

Answer 1

Hinweis: Dies ist nicht getestet:

Erstellen Sie eine ReplaySubject aus beobachtbaren Sequenz a. Für jeden Wert, der in der Sequenz b ausgegeben wird, kombinieren Sie diesen Wert mit dem Wiedergabesubjekt, um eine neue Observable von Pair<A, B> zu erstellen. Stellen Sie diese Observablen zusammen und geben Sie sie als Ergebnis zurück.

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))); 
}