レトロフィットとRxJava、AndroidのマルチスレッドRESTはこの<a href="http://randomdotnext.com/retrofit-rxjava/" rel="nofollow noreferrer">tuto</a>に従った後、私はそうのようなマルチスレッドRESTリクエスト送信することができるよだから私は、リアクティブプログラミングに非常に新しいです

Question

を要求します。

Retrofit2インタフェース：

を

@FormUrlEncoded 
@PUT("path") 
Observable<String> putMethod(
    @Field("field") String field, 
    ... 
); 

Retrofit2ビルダー：

private NetRequestService() { 
    Retrofit retrofit = new Retrofit.Builder() 
      .baseUrl(END_POINT) 
      .addConverterFactory(GsonConverterFactory.create()) 
      .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) 
      .build(); 
    service = retrofit.create(RetrofitInterface.class); 
} 

要求：

public void putMethod(Context context, List<Object> objectList){ 

    for(Object o: objectList) { 
     service.putMethod(
       "field", 
       ... 
     ) 
       .subscribeOn(Schedulers.newThread()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribe(new Subscriber<String>() { 
        @Override 
        public final void onCompleted() { 

        } 

        @Override 
        public final void onError(Throwable e) { 
         Log.e("Error", e.getMessage()); 
        } 

        @Override 
        public final void onNext(String response) { 
         Log.e("Response", response); 
        } 
       }); 
    } 
} 

すべて問題なく動作していますが、onCompleted（）メソッドが呼び出されるたびに問題が発生しますが、service.putMethod（...）の呼び出しが完了した時点を知りたいと思います。どうやってやるの？私はすべての呼び出しが別のアクションを実行するために行われたときに何らかのコールバックをしたいと思います。

おかげ

Answer 1

あなたは、これはあなただけonCompleteのを取得します、しかし、結果を破棄します。この

Observable 
      .fromIterable(list) 
      .flatMap(object -> service.putMethod(/* ... */)) 
      .ignoreElements() 
      .subscribe(/* ... */) 

を行うことができます。結果に興味がある場合は、リストやその他のオブジェクトに入れてください：