1

я новичек в RxJava. Задача следующая: есть 3 запроса

  1. Получение токена
  2. Валидация токена
  3. Получение id сессии

Каждый запрос зависит от ответа предыдущего, т.е. сначала я делаю запрос на получение токена, если токен получен, то нужно передать его во второй запрос на проверку валидности, и затем, если токен прошел валидность, нужно передать его в третий запрос для получения id сессии. Вопрос в том, как это сделать правильно и красиво с помощью RxJava?

Я знаю, что в целом я мог сделать как-то так:

        apiService.createRequestToken()
            .subscribeOn(Schedulers.io())
            .subscribe(object: Observer<RequestTokenResponse> {
                override fun onComplete() { }
                override fun onSubscribe(d: Disposable) { }

                override fun onNext(t: RequestTokenResponse) {
                    apiService.validateRequestToken(username, password, t.requestToken)
                        .subscribeOn(Schedulers.io())
                        .subscribe(object: Observer<RequestTokenResponse> {
                            override fun onComplete() { }
                            override fun onSubscribe(d: Disposable) { }

                            override fun onNext(t: RequestTokenResponse) {
                                apiService.createSession(t.requestToken)
                                    .subscribe(object: Observer<SessionResponse> {
                                        override fun onComplete() { }
                                        override fun onSubscribe(d: Disposable) { }

                                        override fun onNext(t: SessionResponse) {

                                        }

                                        override fun onError(e: Throwable) {
                                            Log.i(TAG, e.localizedMessage)
                                        }
                                    })
                            }

                            override fun onError(e: Throwable) {
                                Log.i(TAG, e.localizedMessage)
                            }
                        })

                }

                override fun onError(e: Throwable) {
                    Log.i(TAG, e.localizedMessage)
                }
            })

Но мне кажется, что есть более компактный и правильный способ.

1 ответ 1

3

Можно действительно проще. Примерно так:

apiService.createRequestToken()
    .switchMap(t -> apiService.validateRequestToken(username, password, t.requestToken).map(ignored -> t))
    .switchMap(t -> apiService.createSession(t.requestToken))
    .subscribe(
        result -> { /*обработка успеха*/ },
        error -> { /*обработка ошибки*/ }
     );
3
  • Спасибо, этот код действительно работает. Есть небольшой вопрос, я правильно понимаю, что если например первый запрос createRequestToken будет неудачный, то следующие запросы выполняться не будут, а ошибка пойдет в блок error?
    – Stenol_53
    Commented 11 авг. 2020 в 11:15
  • @Stenol_53, да всё верно. Ошибка на любом этапе цепочку прервёт и ошибку выдаст в лямбде в subscribe методе.
    – ЮрийСПб
    Commented 11 авг. 2020 в 11:23
  • 1
    Спасибо большое, теперь все стало ясно!
    – Stenol_53
    Commented 11 авг. 2020 в 11:24

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.