2
我从Rx开始使用RxAndroid,我想通过它的API来使用Retrofit列出GitHub用户的名称。每个API请求都会带来100个用户,在我处理了所有想要获得下一个100个用户的用户之后,我不知道该怎么做。任何人都可以帮助我?RxAndroid:同步执行一个可观察的
哪里是我的代码
的更新接口
interface GitHubService {
@GET("/users")
List<User> users(@Query("since") int since);
}
用户类
class User {
private Integer id;
private String login;
public String getLogin() {
return login;
}
public Integer getId() {
return id;
}
}
一些片段和我活动的onCreate方法
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
RequestInterceptor requestInterceptor = new RequestInterceptor() {
@Override
public void intercept(RequestFacade request) {
request.addHeader("User-Agent", "Retrofit-Sample-App");
request.addHeader("Accept", "application/json");
}
};
RestAdapter restAdapter = new RestAdapter.Builder()
.setEndpoint("https://api.github.com")
.setRequestInterceptor(requestInterceptor)
.build();
GitHubService mWebService = restAdapter.create(GitHubService.class);
mWebService.users().flatMap(new Func1<List<User>, Observable<User>>() {
@Override public Observable<User> call(List<User> users) {
return Observable.from(users);
}
}).flatMap(new Func1<User, Observable<String>>(){
@Override public Observable<String> call(User user) {
return Observable.just(user.getId() + ": " + user.getLogin());
}
})
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<String>() {
@Override
public void onCompleted() {
Log.i("TEST", "EXIT");
}
@Override
public void onError(Throwable e) {
Log.i("TEST", e.getLocalizedMessage());
}
@Override
public void onNext(String s) {
Log.i("TEST", s);
}
});
}