小编tom*_*525的帖子

flatMapCompletable不会调用给定的Action

我期望flatMapCompletable在Completable正常完成时会调用给定的Action。但是,它不像我想的那样工作。这是一个简单的例子:

    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
    });
Run Code Online (Sandbox Code Playgroud)

这是预期的行为吗?如果是这样,我如何检查“完成任务”是否已完成?Completable.complete().doFinally()

rx-java rx-java2

2
推荐指数
1
解决办法
5224
查看次数

标签 统计

rx-java ×1

rx-java2 ×1