`zipWith`演算子の中で購読することはできますか？

Question

私はRxJava2を使用していますが、私はその結果に応じて、異なるリストを返す条件を持っているzipWithオペレータはこの

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

     return list3 
    } 
    .flattenAsFlowable() 
    .flatMap() 

のような流動性の機能を持っています。実際、最終的なflatMapはlist3のためのものです。しかし、私はシーケンスを継続しながら、zipWith()オペレータの中でそれを持つ方法を策定することはできません。私はzipWithオペレータの中でそれを包み込むと、依然として購読する必要があると思っています。

どうすればいいですか？

Answer 1

は数時間後、私は最終的にはリストから返す方法zipWith内での流動性を形成し策定しました：

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

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