Ist es möglich, innerhalb eines `zipWith`-Operators zu abonnieren?

Question

Ich verwende RxJava2 und haben eine fließfähige Funktion wie diese

Flowable1 
    .doOnNext() 
    .toList() 
    .onErrorReturnItem() 
    .zipWith(Flowable2 
      .toList() 
      .onErrorReturnItem()){ 
     condition1 -> return list1 
     condition2 -> return list2 

     return list3 
    } 
    .flattenAsFlowable() 
    .flatMap() 

Im zipWith Operator I Bedingungen, die verschiedenen Listen je nach Ergebnis zurück. Und eigentlich ist die final flatMap nur für list3 gedacht. Aber ich kann nicht formulieren, wie man es innerhalb des zipWith() Bedieners hat, während ich noch die Reihenfolge fortsetze. Ich denke, dass ich noch abonnieren müsste, wenn ich es in den zipWith Operator einwickeln würde, der in wirre Fäden resultieren würde

Gibt es einen Weg darum herum?

Answer 1

Nach ein paar Stunden, ich habe einen Weg schließlich formuliert aus einer Liste zurückzukehren, um eine fließfähige innerhalb zipWith bilden:

Flowable1 
    .doOnNext() 
    .toList() 
    .onErrorReturnItem() 
    .zipWith(Flowable2 
      .toList() 
      .onErrorReturnItem()){ 
     condition1 -> return list1 
     condition2 -> return list2 

     return Flowable.fromtIterable(list3) 
        .flatMap() 
        .toList() 
        .blockingGet() 
    } 
    .flattenAsFlowable()