RxJava-主题中的错误处理

Question

我正在尝试在MVVM中实现一个ViewModel，提供可观察的东西作为“输入流”，提供观察者作为“输出流”供视图绑定。

public class ViewModel {

    private final BehaviorSubject<String> query;
    private final BehaviorSubject<User> result;

    public ViewModel() {
        result = BehaviorSubject.create();
        query = BehaviorSubject.create();
        query.flatMap(s -> getUser(s)).subscribe(result);

        //  result = result.doOnError(e -> onError(e));    //  does not work
    }

    Observable<String> login() {
        return result.map(user -> user.getLogin());
    }

    Observable<String> blog() {
        return result.map(user -> user.getBlog());
    }

    public Observer<String> queryObserver() {
        return query;
    }

    private void onError(Throwable e) {
        Log.e(TAG, e.getMessage());
    }
}

Answer 1

doonerror()是一个“辅助操作”运算符，它不捕获错误。应该类似于：

query.flatmap（s->getUser(s)).subscribe（result：：OnNext,This：：OnError）；