Retrofit 2.0で並列要求を制限する方法は？

Question

私の目標は、例外をスローすることによって並列実行要求の数を制限することです。例えば

、私は唯一の実行要求欲しい：

someApi.getUser(
    result -> print("ok: " + result), exception -> print("error: " + exception) 
); // this request will be executed in 5 seconds 

someApi.getServerInfo(
    result -> print("ok: " + result), exception -> print("error: " + exception) 
); // there I want to catch exception like ExecutorIsBusy 

どのように私はレトロフィット2.0でそれを実装することができますか？

Answer 1

私は実際に、@DanielのコメントExceptionを投げることは、それを行うための最良の方法ですが、私はこの点を説明しませんので、私はあなたのユースケースを知らない:)

をとにかくすることを確認していませんかなり良い方向を指しています。 retrofitとOkHttpを使用している場合は、「同時リクエスト」を処理するのはOkHttpClientです。ドキュメントを読むと、OkHttpがDispatcherを使用して並列非同期リクエスト（Dispatcher docs）を処理することがわかります。

ので、2つの興味深いポイントは以下のとおりです。

1. 方法setMaxRequests(int maxRequests)：最大同時要求
2. 方法executed(RealCall call)を定義しています。実際に私はあなたがあなたの目標を達成するために、これを行うことができると思いリクエスト

を実行：

1. カスタムを作成Dispatcherクラス
2. オーバーライド電流要求の数がmaxRequests
3. あなたがretrofitアプローチを取っRxJava &を使用して

Answer 2

で使用しているOkHttpClientでカスタムDispatcherを使用するよりも優れている場合executed(RealCall call)メソッドが例外をスロー上のコメントでは、ここに例があります：

これらの操作はボタンに付けられているものとします。

public void runObservable1(View view) { 
    if (!taskRunning){ 
     try{ 
      taskRunning = true; 
      subsonicService.runTask1() 
        .subscribeOn(Schedulers.io()) 
        .observeOn(AndroidSchedulers.mainThread()) 
        .compose(this.<Result>bindUntilEvent(ActivityEvent.DESTROY)) 
        .subscribe(new Subscriber<Result>() { 
         @Override 
         public void onCompleted() { 
          taskRunning = false; 
         } 

         @Override 
         public void onError(Throwable e) { 

         } 

         @Override 
         public void onNext(Result result) { 
          //your logic here 
         } 
        }); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
    } else { 
     Toast.makeText(this, "Task is running you must wait", Toast.LENGTH_SHORT).show(); 
    } 


} 

public void runObservable2(View view) { 

    if (!taskRunning){ 
     try{ 
      taskRunning = true; 
      subsonicService.runTask2() 
        .subscribeOn(Schedulers.io()) 
        .observeOn(AndroidSchedulers.mainThread()) 
        .compose(this.<Result>bindUntilEvent(ActivityEvent.DESTROY)) 
        .subscribe(new Subscriber<Result>() { 
         @Override 
         public void onCompleted() { 
          taskRunning = false; 
         } 

         @Override 
         public void onError(Throwable e) { 

         } 

         @Override 
         public void onNext(Result result) { 
          //Logic here 
         } 
        }); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
    } else { 
     Toast.makeText(this, "Task is running you must wait", Toast.LENGTH_SHORT).show(); 
    } 
} 

私はRxJavaでもエキスパートではないので、これを簡単にする演算子があるかもしれません。