Товарищи-программисты, которые знают RxJava, скажите, пожалуйста, насколько логичен отрывок кода -
https://pastebin.com/596srDWVА именно:
emitter.onNext(response);
emitter.onComplete();
if (!response.isSuccessful()) emitter.onError(new Exception("error"));
Зачем проверять на успешность запроса после того, как вызвал onComplete()? Только сегодня в документации читал, что может быть вызван либо onComplete, либо onError. А тут сперва onComplete вызывается, а затем, если запрос все таки не увенчался успехом, то отправляем onError. В чем логика?