import rx.functions.Action1;
import rx.functions.Func1;
import rx.schedulers.Schedulers;
public class RxNews {
public static Subscription updateNews(final String newsType) {
<BUG>Subscription subscription = AppService.getNbaPlus().updateNews(newsType)
</BUG>
.subscribeOn(Schedulers.io())
.doOnNext(new Action1<News>() {
@Override

import rx.functions.Action1;
import rx.functions.Func1;
import rx.schedulers.Schedulers;
public class RxNews {
public static Subscription updateNews(final String newsType) {
Subscription subscription = AppService.getNbaplus().updateNews(newsType)
.subscribeOn(Schedulers.io())
.doOnNext(new Action1<News>() {
@Override
