Observable.fromCallable() 方法内部没有被调用

Question

这就是我使用 Observable.fromCallable() 的方式。在其他班级中它工作正常，但在某些班级中则不然。任何帮助将不胜感激。

Observable
.fromCallable(() ->
    getWorkTypeId(tem.getId(), tem.getTypeId())
    .flatMap(oldEntities -> 
        replaceTempAuth(tem.getId(), tem.getTypeId(), 
           getTemes(tem, oldEntities), oldEntities
        )
    )
    .flatMap(deletedEntities -> 
        deleteAllWithId(deletedEntities.stream()
                       .map(TempEntity::getTemId)
                       .collect(Collectors.toList()), tem.getId())
    )
);

这里 replaceTempAuth 方法和 deleteAllWithId 没有被调用。

Answer 1

从@kristyWelsh 得到答案 添加

.subscribe()

效果完美。