Загрузить прогресс с помощью RxJava, Retrofit

Question

В моем проекте я использую шаблон проектирования MVP, RxJava, RxAndroid и Retrofit для использования вызовов API. В настоящее время я ищу решения для попыток отобразить процесс загрузки, пока я отправляю изображение. Я видел пару возможных реализаций, но я боюсь, что они не соответствуют моей реализации. Вот как я использую вызов API с библиотеками, о которых я упоминал:

Subscription subscription = mApiService.modVideoFromVideoController(userHash, videoId, publicVideo, rate) 
       .subscribeOn(Schedulers.newThread()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribe(new Observer<ModifyVideoResponse>() { 
        @Override 
        public void onCompleted() { 
         Log.d(TAG, "modVideo onCompleted"); 
        } 

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

        @Override 
        public void onNext(ModifyVideoResponse modifyVideoResponse) { 
         mVideosPresenter.onVideoEdited(position, publicVideo); 
        } 
       }); 
     mCompositeSubscription.add(subscription); 

Есть ли способ достичь этого?

Answer 1

Лучший способ достичь этого - использовать методы побочных эффектов.

Для прогресса просмотра скрыть/показать:

Bind эти два события с doOnSubscribe() и doFinally(). Это два оператора, поэтому мы можем логически связать их с RxCall.

doOnSubscribe() будет называться, когда вы будете прикреплены к подписчику.

и

doFinaly() будет называться в конце. В любом случае успех или ошибка.