RxJava 从 flatmap 的下游 observable 发出初始值

Question

我有一个用例，我必须将按钮按下转换为数据库获取。我有一个 Observable 从按钮按下。我正在将可观察对象的平面映射到另一个从数据库中获取项目的可观察对象。

Observable<Customer> customerListObservable = getButtonPressObservable()
        .map(event -> new Object())
        .startWith(new Object())
        .flatMap(event -> DatabaseHelper.getDatabase()
                .select("select * from Customer")
                .autoMap(Customer.class)
                .toObservable());

但是，在按下按钮之前，我需要第一次从 db 中获取项目。同样，在随后的按钮按下时，应该再次进行提取。

除了上面的代码还有其他干净的方式来生成初始值吗？

Answer 1

我将连接可观察对象：

Observable<Customer> customerObservable = Observable.concat(getFromDb(), getAfterClick());

private Observable<Customer> getFromDb() {
   return DatabaseHelper.getDatabase()
                .select("select * from Customer")
                .autoMap(Customer.class)
                .toObservable());
}

private Observable<Customer> getAfterClick() {
   return getButtonPressObservable()
        .map(event -> new Object())
        .startWith(new Object())
        .flatMap(event -> getFromDb());
}