Implement OnError

This commit is contained in:
Martin Fietz 2016-03-05 09:15:09 +01:00
parent 5138858e58
commit 89b3df200d
1 changed files with 18 additions and 14 deletions

View File

@ -910,13 +910,17 @@ public abstract class MediaplayerActivity extends AppCompatActivity implements O
Observable.fromCallable(() -> DBReader.getFeedItem(feedItem.getId()))
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(item -> {
.subscribe(
item -> {
boolean isFav = item.isTagged(FeedItem.TAG_FAVORITE);
if(isFavorite != isFav) {
if (isFavorite != isFav) {
isFavorite = isFav;
invalidateOptionsMenu();
}
});
}, error -> {
Log.e(TAG, Log.getStackTraceString(error));
}
);
}
}
}