я новичек в RxJava. Задача следующая: есть 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)
}
})
Но мне кажется, что есть более компактный и правильный способ.