使用Rxjava2的改型2发送GET请求，获取空对象

Question

我知道以前有几个人问过这个问题，但我已经尝试了这些答案。我是Android新手。一切看起来都很好，但我不明白为什么我会得到一个空对象？有人可以指导我吗？

接口：

public interface CryptoAPI {
@GET("ActivityForTestingPurposeOnly/")
io.reactivex.Observable<List<Stream>> getData(@Query("Row") String Row,
                                             @Query("Top") String Top,
                                             @Query("AppID") String appid);

这是我的改装适配器：

public class RetrofitAdapter {
   private String BASE_URL = "http://m.ilmkidunya.com/api/sectionactivity/sectionactivity.asmx/"

   public static CryptoAPI newAPICreator() {
       final HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor();
       interceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
       final OkHttpClient client = new OkHttpClient.Builder()
                                    .addInterceptor(interceptor)
                                    .build();

       Retrofit retrofit = new Retrofit.Builder()
             .client(client)            
             .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
             .addConverterFactory(GsonConverterFactory.create())
             .baseUrl(BASE_URL)
             .build();

            return retrofit.create(CryptoAPI.class);
        }
    }
}

最后，我得到响应的方法：

public void getStreams(){
  CryptoAPI.RetrofitAdapter.newAPICreator()
    .getData("0", "20", "73")
    .subscribeOn(Schedulers.io())
    .subscribeOn(AndroidSchedulers.mainThread())
    .subscribe(new Observer<Stream>() {
        @Override
        public void onSubscribe(Disposable d) {

        }

        @Override
        public void onNext(Stream model) {
                arrayList.add(model);                                  
                Toast.makeText(getApplicationContext(),
                               "Size: " + arrayList.size(),
                               Toast.LENGTH_SHORT);

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

        @Override
        public void onComplete() {

        }
    });
}

> here is my 



    @SerializedName("ID")
    @Expose
    private Integer iD;
    @SerializedName("Rating")
    @Expose
    private Integer rating;
    @SerializedName("SectionID")
    @Expose
    private Integer sectionID;
    @SerializedName("ContentID")
    @Expose
    private Integer contentID;

在这里，您可以在图像中看到

Answer 1

总结

我测试了你给的endpoint一切正常

curl -X GET \
  'http://m.ilmkidunya.com/api/sectionactivity/sectionactivity.asmx/ActivityForTestingPurposeOnly?Row=0&Top=20&AppId=73' \
  -H 'Postman-Token: f64fdf34-4dbb-4201-93e9-e4c95fe7064d' \
  -H 'cache-control: no-cache'

回报是

{
    "stream": [
        {
            "ID": 583750,
            "Rating": 0,
            "SectionID": 59,
            "ContentID": 0,
            "SectionName": "Comments",
            "SortOrder": 2,
            "Title": "ICS",
            ...
        }
    ]
}

出了什么问题

您使用了可观察的

你需要做什么

已更新（基于用户问题更新）

像这样创建一个名为Stream的对象

public class Stream {
     @SerializedName("stream")
     List<StreamItem> streamItems; // <-- Array list of the stream items you have
}

创建一个名为StreamItem的对象，如下所示

public class StreamItem {
     @SerializedName("ID") // <- json key
     Int id;
     @SerializedName("Rating")
     Int rating;
     @SerializedName("SectionID") 
     Int sectionId;
     @SerializedName("ContentID")
     Int contentId;
     @SerializedName("SectionName")
     String sectionName;
     @SerializedName("Title")
     String title;
     ... // additional properties you need
}

然后像这样改变你的api服务接口

io.reactivex.Observable<Stream>

此外，如果您没有将rxjava2与旧的rxjava1或任何相关的可观察类一起使用，您可以直接在服务类的顶部大部分导入可观察类

import io.reactivex.Observable

并像这样使用它

Observable<Stream>

这样做，使用我上面提供的模型对象

public interface CryptoAPI {
@GET("ActivityForTestingPurposeOnly/")
Observable<Stream> getData(@Query("Row") String Row,
                                             @Query("Top") String Top,
                                             @Query("AppID") String appid);

你就是这么叫它的

public void getStreams(){
  CryptoAPI.RetrofitAdapter.newAPICreator()
    .getData("0", "20", "73")
    .subscribeOn(Schedulers.io())
    .subscribeOn(AndroidSchedulers.mainThread())
    .subscribe(new Observer<Stream>() {
        @Override
        public void onSubscribe(Disposable d) {

        }

        @Override
        public void onNext(Stream stream) {
               // IMPORTANT NOTE:
               // Items return here in onNext does not mean the 
               // object you have (eg. each Stream's object in streams' list) 
               // it represents streams of generic data objects


               // This is where you can access the streams array
               arrayList.addAll(stream.streamItems) // <- notice the usage

               Toast.makeText(getApplicationContext(),
                               "Size: " + arrayList.size(),
                               Toast.LENGTH_SHORT);

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

        @Override
        public void onComplete() {

        }
    });
}

阅读更多关于

• http://square.github.io/retrofit/（另请参见第一个示例中如何将array作为根对象解析Github Repos）