Observable.fromCallable() method inside not getting called

37 Views Asked by At

This is how i'm using the Observable.fromCallable(). In other classes its working fine, but not in some of the classes. Any help would be appreciated.

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())
    )
);

Here replaceTempAuth method and deleteAllWithId is not getting called.

1

There are 1 best solutions below

0
AMAN SINGH On BEST ANSWER

Got the answer from @kristyWelsh Added .subscribe() works perfectly.