Как загрузить ResponseBody для нескольких изображений в Retrofit2 (с и без Rx) - PullRequest
Новая
       43

Как загрузить ResponseBody для нескольких изображений в Retrofit2 (с и без Rx)

0 голосов
/ 07 февраля 2019

Я разрабатываю приложение, которое принимает JSON (состоящий из ссылок на изображения), затем через эти ссылки я получаю заголовок ответа и извлекаю contentlength() и contenttype() и source() оттуда в порядкедля записи этих изображений во внешнее хранилище.

Пример JSON: 

[
  {
    "imageUrl": "https://bipbap.ru/wp-content/uploads/2018/01/57a741c2d70811566558e141.png"
  },
  {
    "imageUrl": "https://bipbap.ru/wp-content/uploads/2018/01/57a741c2d70811566558e141.png"
  },
  {
    "imageUrl": "https://bipbap.ru/wp-content/uploads/2018/01/57a741c2d70811566558e141.png"
  },
  {
    "imageUrl": "https://bipbap.ru/wp-content/uploads/2018/01/57a741c2d70811566558e141.png"
  }
]

Пример кода: 

public interface RetrofitApi {

    @GET("bins/xdfi8")
    Call<List<Image>> getImage();

    @GET
    Call<ResponseBody> getImage(@Url String url);
}
</code>

// MainActivity.java 

Retrofit retrofit = new Retrofit.Builder()
                .baseUrl("https://api.myjson.com/")
                .addConverterFactory(GsonConverterFactory.create())
                .build();

     final RetrofitApi retrofitApi = retrofit.create(RetrofitApi.class);

        Call<List<Image>> call = retrofitApi.getImages();


        call.enqueue(new Callback<List<Image>>() {
            @Override
            public void onResponse(Call<List<Image>> call, Response<List<Image>> response) {

                if (!response.isSuccessful()) {
                    textViewResult.setText("Code: " + response.code());
                    return;
                }

                List<Image> images = response.body();

                for (Image image : images) {
                    Call<ResponseBody> responseBodyCall = retrofitApi.getResponseBody(image.getImageUrl());
                    responseBodyCall.enqueue(new Callback<ResponseBody>() {
                        @Override
                        public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
                            String content = "";
                            content += response.body().contentType().subtype() + "\n";
                            content += response.body().contentLength() + "\n\n";
                            // for example print contenttype and contentlength in TextView
                            textViewResult.append(content);
                        }

                        @Override
                        public void onFailure(Call<ResponseBody> call, Throwable t) {

                        }
                    });

            @Override
            public void onFailure(Call<List<Image>> call, Throwable t) {

            }
});
}

}

Image.java 

   public class Image {

    public String getImageUrl() {
        return imageUrl;
    }

    public void setImageUrl(String imageUrl) {
        this.imageUrl = imageUrl;
    }

    private String imageUrl;
}

В данный момент один вызов переводится в другой, как его избежать?

Также интересует методесли бы мы использовали RxJava и RetrofitApi приняли бы эту форму: 

public interface RetrofitApi {

    @GET("bins/xdfi8")
    Observable<List<Image>> getImage();

    @GET
    Observable<Response<ResponseBody>> getImage(@Url String url);
}

1 Ответ

0 голосов
/ 08 февраля 2019

Допустим, у вас есть этот API: 

public interface RetrofitApi {

    @GET("bins/xdfi8")
    Observable<List<Image>> getImage();

    @GET
    Observable<Response<ResponseBody>> getImage(@Url String url);
}

Затем в деятельности: 

Retrofit retrofit = new Retrofit.Builder()
    .baseUrl("https://api.myjson.com/")
    .addConverterFactory(GsonConverterFactory.create())
    .build();

final RetrofitApi retrofitApi = retrofit.create(RetrofitApi.class);

retrofitApi.getImages() // Observable<List<Image>>
    .flatMapIterable(images -> images) // Observable<Image>
    .flatMap(image -> retrofitApi.getImage(image.getImageUrl()))
            .onErrorResumeNext(Observable.empty())) // Observable<ResponseBody>
    .subscribeOn(Schedulers.io()) // run using io scheduler
    .observeOn(AndroidSchedulers.mainThread()) // observe in main thread
    .subscribe(result -> {
        ...
        textViewResult.append(content);
    }, error -> {
        textViewResult.setText("Code: " + error);
    })
...