### Question:
TopicService extends BaseService<List<Topic>> { private void getHot(){ topicApi.getHotTopic().compose(jsonArrayResolver()).subscribe(mObserver); } TopicService(IResponsibleView v, ResponseListener<List<Topic>> topicListener); void getTopic(Tab type, int page); static void postTopic(IResponsibleView iResponsibleView,
                          String title,
                          String content,
                          String node,
                          ResponseListener<Topic> listener); static void getTopicByNode(IResponsibleView view,
                                      String node,
                                      int page,
                                      ResponseListener<List<Topic>> listener); static void getTopicAndReply(IResponsibleView responsibleView,
                                        int topicId,
                                        int page,
                                        ResponseListener<Topic> listener); static void postReply(IResponsibleView responsibleView,
                                 Topic topic,
                                 String content,
                                 ResponseListener<String> responseListener); static void getReply(IResponsibleView responsibleView,
                                int topicId,
                                int page,
                                ResponseListener<List<Reply>> listener); void getReplyFromApi(Topic topic, int page);  }### Answer:
@Test public void getHot() { RetrofitManager.create(TopicApi.class) .getHotTopic() .subscribe(new RxObserver<JsonArray>() { @Override public void _onNext(JsonArray jsonElements) { jsonElements.forEach(jsonElement -> { Topic topic = new Gson().fromJson(jsonElement, Topic.class); System.out.println(topic.getTitle()); System.out.print(topic.getReplies()); System.out.print(topic.getReplies()); System.out.print(topic.getContent()); }); } @Override public void _onError(String msg) { System.err.println(msg); } }); }