使用 RxAndroid 集成进行改造 [关闭]

Question

我使用 Retrofit 来调用 Restful API。我阅读了 Rx Android 的一些帖子，但我不知道如何以新定义的可观察模式将 Rx Android 与 Retrofit 集成。 我指的链接来自谷歌搜索。但没有弄清楚如何实现它，所以我想要适当的例子或任何帖子来学习。

Answer 1

如果您要切换到 RxAndroid，我建议您从：http://blog.danlew.net/2014/09/15/grokking-rxjava-part-1 开始。帖子中，作者细心讲解，系列一共4篇。

然后您可以阅读更多关于 Retrofit2 的内容：https://realm.io/news/droidcon-jake-wharton-simple-http-retrofit-2/；有 Call、Observable 和 Future 的例子。

从使用 Observable 从 onNext 获取期望输出的简单 hello world（类似于 Callback）：

Observable<String> myObservable = Observable.create(
    new Observable.OnSubscribe<String>() {
        @Override
        public void call(Subscriber<? super String> sub) {
            sub.onNext("Hello, world!");
            sub.onCompleted();
        }
    }
);

Subscriber<String> mySubscriber = new Subscriber<String>() {
    @Override
    public void onNext(String s) { System.out.println(s); }

    @Override
    public void onCompleted() { }

    @Override
    public void onError(Throwable e) { }
};

myObservable.subscribe(mySubscriber);
// Outputs "Hello, world!"

然后我们可以像这样实现 Retrofit2：

interface GitHubService {
  @GET("/repos/{owner}/{repo}/contributors")
  Observable<List<Contributor>> repoContributors(
      @Path("owner") String owner,
      @Path("repo") String repo);
}

Subscriber<List<Contributor>> repoSubscriber = new Subscriber<List<Contributor>>() {
    @Override
    public void onNext(List<Contributor> list) { 

         // do something with the list 
    }


    @Override
    public void onCompleted() { }

    @Override
    public void onError(Throwable e) { }
};

gitHubService.repoContributors("square", "retrofit")
    .subscribe(repoSubscriber);

您可以使用 Action1 以及订阅者。

gitHubService.repoContributors("square", "retrofit")
    .subscribe(new Action1<List<Contributor>>() {
      @Override public void call(List<Contributor> contributors) {
        // ...
      }
    });