CODEWITHSUNDEEP
androidobservablerx-java2greendao
AMAN SINGH
AMAN SINGH

Reputation: 3561

Observable.fromCallable() method inside not getting called

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.

Upvotes: 0

Views: 45

Answers (1)

AMAN SINGH
AMAN SINGH

Reputation: 3561

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

Upvotes: 0

Related Questions