Rxjava2 и Retrofit2 Множественные/параллельные/одновременные вызовы api(post) в разных потоках

В то время, когда вы отправляете самый первый запрос POST, переменное значение request уже равно 4. Это потому, что после того, как вы щелкнете 4 раза, первый запрос POST примет request в то время (с 4), а не request в то время устанавливается его изменяющееся значение.

Решение заключается в том, чтобы сделать объект request локальным внутри метода onClick().

public void onClick(View v) {
    RequestClass request = new RequestClass();
    request.setName("rober");
    request.setVarryingValue(count);

    //Your code
}

Или присвойте значение count временной переменной и установите его в request прямо перед отправкой POST-запроса, но следите за потокобезопасностью.

public void onClick(View v) {
    //Saving the value
    int temp = count++;
    request.setName("rober");

    mApiService.apiService()
            .getAccessToken(<params>)
            .subscribeOn(Schedulers.newThread())
            .flatMap(new Function<Auth, ObservableSource<?>>() {
                @Override
                public ObservableSource<?> apply(Auth authentication) throws Exception {
                    //Set it to the request
                    //BE CAREFUL  because the `request` object is now being accessed from multiple threads
                    request.setVarryingValue(temp);

                    Observable<Void> postObservable = 
                        mApiService
                            .apiService()
                            .postCall(request, authentication.getAuth())
                            .subscribeOn(Schedulers.io())
                            .subscribe();

                    return postObservable;
                }
            })
            .subscribe();
}

Мне не совсем понятно, почему все почтовые запросы выполняются одновременно, полный журнал с onClick() временем и getAccessToken() запросами, и onNext() выбросами может помочь.

Кажется, ваш код делает это правильно, вы будете открывать новый поток для каждого запроса.
Но, так или иначе, поскольку у вас есть 4 отпечатка в вашем журнале, но все они имеют одинаковое количество, проблема, вероятно, связана с параметром request является полем и, таким образом, используется совместно и доступно после getAccessToken() создания элемента, таким образом, вы в основном выполняете 4 запроса, но с одними и теми же данными.
Вы должны назначить для каждого нового созданного flatMap() выделенную переменную счетчика.

Кроме того, неправильно подписываться на postObservable внутри оператора flatMap(), вы должны просто вернуть его, и поток подпишется на него и объединит его обратно в виде onNext() выбросов.
С вашим кодом вы выполняете каждый пост-запрос < strong>дважды, один явно вами, а другой оператором flatMap() (это также может объяснить наличие нескольких журналов одного и того же запроса, но опять же трудно сказать, не видя всех данных в журнале).

Основываясь на обоих предложенных вами ответах, я придумал следующий код:

• Запрос стал локальной переменной вместо поля
• Удаление подписки внутри плоской карты

• Привязал его к onNext внешнего наблюдаемого

  @Override
  public void onClick(View v) {
  
  count++;
  Request request = new Request();
  request.setName("rober");
  request.setVarryingValue(count);
  
  mApiService.apiService()
          .getAccessToken(<params>)             
          .subscribeOn(Schedulers.io())
          .flatMap(new Function<Auth, ObservableSource<Void>>() {
              @Override
              public ObservableSource<Void> apply(Auth authentication) throws Exception {
                  return mApiService.apiService().postCall(request, authentication.getAuth());
              }
          })  
          .subscribe(new Observer<ObservableSource<Void>>() {
  
              @Override
              public void onSubscribe(Disposable d) {}
  
              @Override
              public void onNext(ObservableSource<Void> sourceFromFlatMap) {
  
                  sourceFromFlatMap.subscribe(new Observer<Void>() {
  
                      @Override
                      public void onSubscribe(Disposable d) {}
  
                      @Override
                      public void onNext(Void value) {
                      }
  
                      @Override
                      public void onError(Throwable e) {}
  
                      @Override
                      public void onComplete() {}
                  });
              }
  
              @Override
              public void onError(Throwable e) {}
  
              @Override
              public void onComplete() {}
          });
   });
  

хотя я до сих пор не уверен, правильно ли я использую Rx