flatMapCompletableが指定されたアクションを呼び出さない

Question

Completableが正常に完了したときにflatMapCompletableが指定されたアクションを呼び出すと予想していました。しかし、私は思った通りに動作しません。ここに簡単な例があります：

PublishProcessor<String> processor = PublishProcessor.create(); 

    processor.flatMapCompletable(s2 -> { 
     System.out.println("s2 " + s2); 
     return Completable.complete(); 
    }).subscribe(() -> { 
     System.out.println("done"); // it does not come here 
    }); 

この現象は予期しないものですか？もしそうなら、Completableタスクが完了したかどうかを確認するには？ Completable.complete().doFinally()？

Answer 1

アクションオンコンプリートを取得するには、processor.onComplete();に電話する必要があります。これは、着信イベントをリッスンしている間は、依然としてサブジェクトにサブスクライブしているためです。

Flowableは通常

Flowable.just(1).flatMapCompletable(s2 -> { 
     System.out.println("s2 " + s2); 
     return Completable.complete(); 
    }).subscribe(() -> { 
     System.out.println("done"); // it does come here 
    }); 

Answer 2

を完了したアレクサンダーが指摘したように、あなたは何を得ることはありません理由はPublishProcessor完了したことがないです。

JavaDocflatmapCompletable注意事項は次のとおりです。

上流Observableの各要素をCompletableSourcesにマップし、それらにサブスクライブし、上流およびすべてのCompletableSourcesが完了するまで待ちます。

したがって、上流のObservableとすべてのCompletableSourceがイベントを受け取るために完了していることを確認する必要があります。

ありがとうございました。