dependencies {
...
implementation 'io.reactivex.rxjava2:rxandroid:x.y.z'
...
}
public Observable<Article> getArticle(String articleId) {
return Observable.create(emitter -> {
try {
Article article = apiService.getArticle(articleId).execute().body();
emitter.onNext(article);
emitter.onComplete();
} catch (IOException e) {
emitter.onError(e);
}
});
}
public class MainActivity extends AppCompatActivity {
private CompositeDisposable disposable = new CompositeDisposable();
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
Observable<Article> articleObservable = getArticle("123");
disposable.add(articleObservable
.subscribe(
article -> {
},
error -> {
}
)
);
}
@Override
protected void onDestroy() {
super.onDestroy();
}
}
