Android Volley RxJava - Множественные запросы

Question

У меня есть что-то вроде этого:

public void function sendPhotosAndSave (ArrayList<Photo> photos) { 

    // Iterate through all photos 
    // Send a POST request using volley for each photo 
    // Alert when all photos sended 

    // ???? 
    .subscribe(new Subscriber<Boolean>() { 
      @Override 
      public void onCompleted() { 
       // Save 
      } 

      @Override 
      public void onError(Throwable e) { 

      } 

      @Override 
      public void onNext(Boolean aBoolean) { 

      } 
     }); 

} 

Мне нужно отправить все фотографии (Multipart/POST), а затем отправить запрос на сохранение.

Как выполнить итерацию запросов фотографий с использованием RxJava и узнать, когда это будет сделано?

Answer 1

Вы можете сделать что-то вроде этого:

public void sendPhotosAndSave(List<Photo> photos) { 
     Observable.from(photos) 
       .flatMap(photo -> sendRequest(photo).subscribeOn(Schedulers.io())) 
       .subscribe(new Subscriber<Boolean>() { 
        @Override 
        public void onCompleted() { 
         // Save 
        } 

        @Override 
        public void onError(Throwable e) { 

        } 

        @Override 
        public void onNext(Boolean aBoolean) { 

        } 
       }); 
    } 

    private Observable<Boolean> sendRequest(Photo photo) { 
     return Observable.just(/*your request logic*/); 
    }