Прогресс загрузки с RxJava, OkHttp и Okio в Android

В нашем приложении я загружаю файл изображения с этим кодом. Мне нужно показать ход загрузки (скачанные байты в процентах) в пользовательском интерфейсе. Как я могу получить прогресс загрузки в этом коде? Я искал решение, но до сих пор не могу сделать это самостоятельно.

Observable<String> downloadObservable = Observable.create(
                    sub -> {
                        Request request = new Request.Builder()
                                .url(media.getMediaUrl())
                                .build();
                        Response response = null;
                        try {
                            response = http_client.newCall(request).execute();
                            if (response.isSuccessful()) {
                                Log.d(TAG, "response.isSuccessful()");
                                String mimeType = MimeTypeMap.getFileExtensionFromUrl(media.getMediaUrl());
                                File file = new File(helper.getTmpFolder() + "/" + helper.generateUniqueName() + "test." + mimeType);
                                BufferedSink sink = Okio.buffer(Okio.sink(file));
                                sink.writeAll(response.body().source());
                                sink.close();
                                sub.onNext(response.toString());
                                sub.onCompleted();
                            } else {
                                sub.onError(new IOException());
                            }
                        } catch (IOException e) {
                            e.printStackTrace();
                        }

                    }
            );

            Subscriber<String> mySubscriber = new Subscriber<String>() {
                @Override
                public void onNext(String responseString) {
                    Log.d(TAG, "works: " + responseString);
                }
            };
            downloadObservable
                    .subscribeOn(Schedulers.newThread())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(mySubscriber);

android okhttp rx-java okio
person Rafael    schedule 30.04.2015    source источник
comment
нашел хороший пример, связанный с моим вопросом danosipov.com/?p=678   -  person Rafael    schedule 30.04.2015

Ответы (1)


arrow_upward
24
arrow_downward

Это то, что я сделал бы, чтобы показать прогресс.

Observable<String> downloadObservable = Observable.create(
  sub -> {
          InputStream input = null;
          OutputStream output = null;
          try {
          Response response = http_client.newCall(request).execute();
           if (response.isSuccessful()) {                 
             input = response.body().byteStream();
             long tlength= response.body().contentLength();

             output = new FileOutputStream("/pathtofile");
             byte data[] = new byte[1024];

             sub.onNext("0%");
             long total = 0;
             int count;
             while ((count = input.read(data)) != -1) {
               total += count;

               sub.onNext(String.valueOf(total*100/tlength) + "%");

               output.write(data, 0, count);
             }
             output.flush();
             output.close();
             input.close();
           }
          } catch(IOException e){
            sub.onError(e);
          } finally {
                if (input != null){
                    try {
                        input.close();
                    }catch(IOException ioe){}
                }
                if (out != null){
                    try{
                        output.close();
                    }catch (IOException e){}                        
                }
          }
        sub.onCompleted();
   }
);

И используйте подписчика, который имеет полные абстрактные методы.

Subscriber<String> mySubscriber = new Subscriber<String>() {

@Override
public void onCompleted() {
  // hide progress bar
}

@Override
public void onError(Throwable e) {
  // hide progress bar
}

@Override
public void onNext(String percentProgress) {
  // show percentage progress
}
};
person inmyth    schedule 30.04.2015
comment
Я имею в виду, что мне нужно показать загруженный прогресс в процентах - person Rafael; 30.04.2015
comment
Я обновил свой ответ, но не знаю Окио, поэтому не могу об этом рассказать. - person inmyth; 30.04.2015
comment
Работал как шарм. Я использую модификацию, и стало довольно сложно загрузить простой файл. - person harsh_v; 21.01.2016
comment
@inmyth response.body().contentLength() всегда возвращает -1 для меня - person H Raval; 12.07.2016
comment
@inmyth как ты мог получить доступ к файлу? - person nani; 10.11.2016
comment
Согласитесь с @nani, смысл этого Observable состоит в том, чтобы вернуть файл, а прогресс не является основной частью. Я не думаю, что это должен быть одобренный ответ - person Dominik Mičuta; 31.03.2017
comment
Почему люди продолжают рекомендовать Observable.create? Это НЕ то, как вы должны поступать. - person Noah Andrews; 16.06.2017
comment
@NoahAndrews Вы оставляете такой комментарий через 2 года после публикации ответа. Не могу сказать, продолжайте рекомендовать, как этот ответ был только что опубликован. - person Dmitry Avtonomov; 28.04.2020