2

私は RxAndroid で Rx を開始しています。Retrofit を使用して API で GitHub ユーザーの名前をリストしたいと考えています。各 API リクエストは 100 人のユーザーを取得します。すべてのユーザーを処理した後、次の 100 人を取得したいのですが、その方法がわかりません。誰でも私を助けることができますか？

私のコードのスニペットはどこにありますか

改造インターフェース

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);
            }
        });

}
4

1 に答える 1

0 
    BehaviorSubject<Integer> pagingSubject = BehaviorSubject.create();

    // subscribe to this observable and do with data whatever you want
    Observable<List<User>> usersObservable = pagingSubject.flatMap(page -> mWebService.users(page)); 

    // fetch pages
    pagingSubject.onNext(1);
    pagingSubject.onNext(2);

上記のように、サブジェクトを使用して取得したいページを渡すことができます。リクエストが完了した後に pagingSubject.onNext(page) を呼び出すことができます (Github ユーザーのリクエストがどのように表示されるかは確認していませんが、応答で次のリクエストの「since」パラメーターを取得する可能性があります)。

于 2015-02-09T15:05:05.500 に答える