java - 连接并返回 Observable

Question

我试图弄清楚如何从网络中获取结果，持久化它并将响应主体返回给 Observable。像这样:

@Override
    public Observable<DefaultUserResponse> createUser(CreateUserCommand command) {
        return this.userService.createUser(command)
                .map(defaultUserResponse -> {
                    User user = new User();
                    defaultUserResponse.setUser(user);
                    return defaultUserResponse;
                }).flatMap(defaultUserResponse -> persist(defaultUserResponse.getUser()));
    }

Observable<User> persist(User user) {return null;}

步骤:

1. 我从服务器获得了 DefaultUserResponse。
2. 将命令转换为用户 (command = DTO)
3. 在本地保留用户。
4. 返回 DefaultUserResponse。

我应该如何进行？

谢谢

Answer 1

考虑使用 Completable为您的持久方法键入(如果您不关心返回值):

Completable persist(User user) {
    return Completable.fromCallable(() -> {
        //persisting
        return null;
    }
}

然后您可以使用 andThen 运算符等待持久化完成并进一步插入您的值(value):

...
.flatMap(defaultUserResponse -> persist(defaultUserResponse.getUser()).andThen(Observable.just(defaultUserResponse)));

或者，如果您仍想使用 Observable 进行持久化，只需使用另一个 flatMap 而不是 andThen。