RxJava与retrofit结合使用
2018-06-04 本文已影响0人
远远飘着云
@GET("/user")public Observable getUser(@Query("userId") String userId);
getUser(userId) .doOnNext(new Action1() { @Override public void call(User user) { processUser(user); }) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer() {
@Override
public void onNext(User user) {
userView.setUser(user);
}
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable error) {
// Error handling
...
}
});
getUser(userId)属于Observable类型.所以RxJava和Retrofit相结合的方式如上.
