private void doTransaction() {

       addDisposable(Single.create((SingleOnSubscribe<TaxTransaction>) e -> {
           try {
               if (!e.isDisposed()) {
                   e.onSuccess(createTransactionModel());
               }
           } catch (Exception ex) {
               e.onError(ex);
           }
       })
               .subscribeOn(Schedulers.io())
               .observeOn(AndroidSchedulers.mainThread())
               .doOnSubscribe(disposable -> getProgressLiveData().postValue(true))
               .doAfterTerminate(() -> getProgressLiveData().postValue(false))
               .subscribeWith(new DisposableSingleObserver<TaxTransaction>() {
                   @Override
                   public void onSuccess(TaxTransaction model) {
                       sendTransactionToRest(model);
                   }

                   @Override
                   public void onError(Throwable e) {
                       e.printStackTrace();
                   }
               }));
   }

private void sendTransactionToRest(TaxTransaction model) {
       addDisposable(
               provider
                       .doTransaction(model)
                       .doOnSubscribe(disposable -> getProgressLiveData().postValue(true))
                       .doAfterTerminate(() -> getProgressLiveData().postValue(false))
                       .subscribeWith(new DisposableSingleObserver<Response<TaxTransactionCard>>() {
                           @Override
                           public void onSuccess(Response<TaxTransactionCard> response) {
                               switch (response.code()) {
                                   case 200:
                                       Timber.tag("ЦЦЦЦ").i("sendTransactionToRest: body -> " + response.body());

                                       myResponse = response.body();

                                       payBtnClickLiveEvent.postValue(PreferenceUtil.getInstance(context).getString(PreferenceUtil.USER_PHONE, StringUtil.EMPTY));
                                       break;
                                   case 401:
                                       showTokenResetDialog();
                                       break;
                                   default:
                                       showErrorMessage(response.errorBody());
                                       break;
                               }
                           }

                           @Override
                           public void onError(Throwable e) {
                               showErrorMessage(null);
                           }
                       })
       );

   }

))))

Лучше pastbin или GitHub gist воспользоваться для передачи кода

в телеге можно передать код как код

triple `

все же в спец тулзах удобнее читать, потому что 1) подсветка кода, 2) не забивать чат простыней кода

 some code

но он переносит то что не влезло, что тоже некрасиво

Ладно господа я всех вас понял )

😆

Но можете посоветовать как исправить ситуацию

просто твой код здесь тяжело читается, там почти каждая строчка важна

ЦЦЦЦ

Вопроса не понял, но если речь идет о том, чтобы одно подождало пока исполнилось другое, то нужно использовать concatMap

В то время как что-то новое прилетает сверху

корутины не пробывал ?

там функция await есть

Нет

Несколько бесплатных онлайн курсов по Kotlin

#kotlin #course

https://blog.kotlin-academy.com/best-kotlin-free-online-courses-5838cb7063c6