-3
如何取消訂閱RxJava2中的可觀察或訂閱?或者我真的需要嗎?如何取消訂閱RxJava2中的可觀察或訂閱?或者我真的需要嗎?
//Initialising Obersvable
Observable<SearchSuggestions> observable = NetworkContext.api.getSearch("");
//subscribing obersvable on another thread and observing on main thread
observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<SearchSuggestions>() {
@Override
public void accept(SearchSuggestions searchSuggestions) throws Exception {
// here I receive the fetched results
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
//here the error
}
});
請閱讀[this](https://github.com/ReactiveX/RxJava/wiki/What's-different-in-2.0#subscriber)。 – akarnokd