flatMapCompletable не вызывает данное действие

Question

Я ожидал, что flatMapCompletable вызовет данное действие, когда Completable завершится нормально. Однако это не работает, как я думал. Вот простой пример:

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.complete().doFinally()?

Answer 1

Для того, чтобы активировать действие onComplete, необходимо позвонить по телефону 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 никогда не завершается.

JavaDoc из flatmapCompletable Примечания как указано ниже.

Отображает каждый элемент восходящего канала Observable в CompletableSources, подписывается на них и ожидает завершения восходящего и всех заполненных источников.

Для того,

Спасибо.