Как получить JSONArray, используя retrofit2 и RXJava2 - PullRequest
Новая
       47

Как получить JSONArray, используя retrofit2 и RXJava2

0 голосов
/ 12 марта 2020

Я использую Retrofit2 и RxJava2 для получения данных с сервера. У меня есть ответ в следующем формате: 

 {
   "product_data": [
    {
        "product_name": "Pi-Pi jod kar ye Notebook li hai",
        "product_price": "249.00",
        "category_id": "9",
        "product_id": "125",
        "product_photo": "1574935198_1.jpg"
    },
    {
        "product_name": "Tere Jesa year kaha kaha esa yarana",
        "product_price": "249.00",
        "category_id": "9",
        "product_id": "128",
         "product_photo": "1574935455_1.jpg"
     }
    ]
   }

Я получаю исключение ниже: 

Expected BEGIN_ARRAY but was BEGIN_OBJECT at line 1 column 2 path $.

ApiService.class 

public interface ApiService {

@GET("general_cat_api")
Observable<List<HomeGeneralModel>> getData();

}

RetrofitClient.class 

public class RetrofitClient {

private static Retrofit retrofit = null;

public static Retrofit getInstance(){


    OkHttpClient okHttpClient = new OkHttpClient.Builder()
            .connectTimeout(22, TimeUnit.SECONDS)
            .readTimeout(22, TimeUnit.SECONDS)
            .writeTimeout(22, TimeUnit.SECONDS)
            .build();

    if(retrofit == null)
        retrofit = new Retrofit.Builder()
                .baseUrl("http://aamku.com/api/")
                .addConverterFactory(GsonConverterFactory.create(new GsonBuilder().setLenient().create()))
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .client(okHttpClient)
                .build();

    return retrofit;

}

private RetrofitClient(){

  }
}

Теперь я использую модификацию, как показано ниже, для извлечения данных: 

private void getData(){

    Retrofit retrofit = RetrofitClient.getInstance();
    ApiService myApi = retrofit.create(ApiService.class);

    myApi.getData().subscribeOn(Schedulers.io())
                   .observeOn(AndroidSchedulers.mainThread())
                   .subscribe(new Observer<List<MenuModel>>() {
                       @Override
                       public void onSubscribe(Disposable d) {

                       }

                       @Override
                       public void onNext(List<MenuModel> menuModels) {

                           if(menuModels.size() > 0){

                               menuProg.setVisibility(View.INVISIBLE);
                               list.addAll(menuModels);

                               adapter = new MenuAdapter(list,MainActivity.this);
                               menuRecycler.setAdapter(adapter);
                           }
                       }

                       @Override
                       public void onError(Throwable e) {

                           menuProg.setVisibility(View.INVISIBLE);
                           Toast.makeText(getApplicationContext(),e.getMessage(),Toast.LENGTH_SHORT).show();
                       }

                       @Override
                       public void onComplete() {

                       }
                   });
}

Кто-то, пожалуйста, дайте мне знать, почему я получаю это исключение. Любая помощь будет принята.

СПАСИБО

1 Ответ

0 голосов
/ 12 марта 2020

Ваш формат ответа здесь неправильный 

Observable<List<HomeGeneralModel>> getData();

Поскольку вы получаете json объект в ответ, вам не нужен список. Используйте HomeGeneralModel непосредственно в наблюдаемом.

Ваш список product_data должен быть внутри HomeGeneral Model

Это должно быть так 

  Observable<HomeGeneralModel> getData();
...