RxApolloClient

RxApolloClient.java

  ApolloWatcher<EpisodeHeroName.Data> watcher = apolloClient.newCall(query).watcher();

    RxApollo
        .toObservable(watcher)
        .subscribe(new Observer<EpisodeHeroName.Data>() {
          @Override public void onCompleted() {

          }

          @Override public void onError(Throwable e) {

          }

          @Override public void onNext(EpisodeHeroName.Data data) {

          }
        });