Android的凌空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) { 

      } 
     }); 

} 

我需要發送的所有照片（多部分/ 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*/); 
    }