使用REST从firebase检索信息并使用Reformation和RxJava进行解析时出现问题

Question

我一直在努力使用REST API响应处理Firebase响应。问题是我不想在Firebase中使用Android的libs，而是使用原始rest api。长话短说，Firebase的回应是：

{
    "object1": {
        "param1": true,
        "param2": "05",
        "param3": "String",
    },
    "object2": {
        "param1": true,
        "param2": "09",
        "param3": "String",
    }
}

改装接口：

public interface ApiCalls {
    @GET("/objects.json")
    Observable<List<MyObject>> getObjects();
}

Gson Builder、改装Builder和RxJava：

    Gson gson = new GsonBuilder()
            .setLenient()
            .create();

    Retrofit retrofit = new Retrofit.Builder()
            .baseUrl("https://my-service.firebaseio.com")
            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
            .addConverterFactory(GsonConverterFactory.create(gson))
            .client(okHttpClient)
            .build();

    ApiCalls api = retrofit.create(ApiCalls.class);

    rx.Observable<List<MyObject>> call2 = api.getObjects();
    call2.subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Subscriber<List<MyObject>>() {
                @Override
                public void onCompleted() {
                    Log.d("onCompleted", "Its completed");
                }

                @Override
                public void onError(Throwable e) {
                    Log.d("onError", e.getMessage());
                }

                @Override
                public void onNext(List<MyObject> MyObjects) {
                    Log.d("onNext", "NextItem");
                }
            });

执行此操作时，我会得到错误：

java.lang.IllegalStateException: Expected BEGIN_ARRAY but was BEGIN_OBJECT at line 1 column 2 path $

为了迭代来自服务器的对象列表，是否可以使用RxJava解决这个问题？从现在起，我期待一个数组，但firebase的响应不是数组，是否有任何方法可以解决这个问题？

Answer 1

好吧，多亏了这句话，我可以解决这个问题：

@VeereshCharantimath这确实是错误的原因：Firebase中的JSON是一个地图（Map），而不是列表。想发布答案吗？-Frank van Puffelen

在我修改了响应的预期值后，它开始工作：

改装Api调用

public interface ApiCalls {
    @GET("/objects.json")
    Observable<HashMap<String, MyObject>> getObjects();
}

RxJava

rx.Observable<HashMap<String, MyObject>> call2 = api.getObjects();
call2.subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<HashMap<String, MyObject>>() {
            @Override
            public void onCompleted() {
                Log.d("onCompleted", "Its completed");
            }

            @Override
            public void onError(Throwable e) {
                Log.d("onError", e.getMessage());
            }

            @Override
            public void onNext(HashMap<String, MyObject> MyObjects) {
                Log.d("onNext", "NextItem");
            }
        });