我期望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()?