Переопределить / расширить Rx Java потребителей - PullRequest
Новая
       19

Переопределить / расширить Rx Java потребителей

0 голосов
/ 26 февраля 2020

Я новичок в RxJava2, и я хочу создать такой тип поведения: 

class LoginController{
    void login(){
    loginService.login().doOnError(throwable -> {
       System.out.println("Higher level error");
    }.subscribe();
  }
}

Служба: 

class LoginService{
 public Single<String> login() {
    return doLogin()
      .doOnError(throwable -> {
          System.out.println("Lower level error");
       ).singleOrError();
}

Когда я подпишусь на LoginController, я получу только печать "Ошибка более высокого уровня ». Чего я хотел бы добиться, так это распечатать оба сообщения. Дело в том, что я хочу иметь некоторые базовые логи c для этой ошибки, которые я могу расширить в других местах.

...