Я реализовал сетевой вызов для проверки входа в систему, который работает нормально. Я просто столкнулся с проблемой при выполнении другого вызова для получения данных пользователя после успешного входа в систему.
Вот вызов API:
RestApi restApi = ServiceRest.createRetrofitService(RestApi.class, UrlServer.URL_SERVER);
Observable<Response<User>> responseObservable = restApi.getUser(user);
responseObservable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.unsubscribeOn(Schedulers.io())
.subscribe(new Subscriber<Response<User>>() {
@Override
public void onCompleted() {
Log.i("LoginActivity", "[onCompleted]");
progressDialog.dismiss();
}
@Override
public void onError(Throwable e) {
progressDialog.dismiss();
Toast.makeText(LoginActivity.this, "Error: " + e.getMessage(), Toast.LENGTH_SHORT).show();
}
@Override
public void onNext(Response<User> userResponse) {
//Do stuff to go to another Activity
}
});
------------- Редактировать №1 -------------
Я реализовал то, что предложил @Tassos, следующим образом:
responseUser
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.map(new Func1<Response<User>, Observable<Response<Object>>>() {
@Override
public Observable<Response<Object>> call(Response<User> userResponse) {
Log.d("USER", userResponse.body().getName());
return restApi.getData(userResponse.body().getToken());
}
})
.doOnError(new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
Toast.makeText(LoginActivity.this, "Error[doOnError]: " + throwable.toString(), Toast.LENGTH_SHORT).show();
}
})
.subscribe(new Subscriber<Object>() {
@Override
public void onCompleted() {
Log.i("LoginActivity", "[onCompleted]");
}
@Override
public void onError(Throwable e) {
Toast.makeText(LoginActivity.this, "Error: " + e.getMessage(), Toast.LENGTH_SHORT).show();
}
@Override
public void onNext(Object result) {
Log.d("RESPONSE", result.toString());
}
});
Правильно ли делать так в методе подписки? Нужно ли мне приводить результат объекта onNext?
//---------------------------------------------------------------------------- ------------------------------//
Я хочу после успешного входа в систему вызвать другой URL-адрес, используя токен, полученный через пользователя объекта Response, и отправить его на другой вызов API (Observable<Response<Object>> getData(@Header("Authorization") String token);
) в качестве авторизации заголовка. Я пробовал использовать flatMap и zip, но не смог выполнить эту задачу.
Есть советы? Эта концепция для меня новая.