rxJava：用可完成组合单曲并返回单曲

Question

我的步骤是：

1. 创建单个值 x - 可能会占用一点 CPU 资源
2. 使用值 x 执行 IO 操作。这已经返回Completable
3. 返回 x

所以我想这样做：

Single<Integer> result = 
             Single.fromCallable(() -> generate_x)
                .COMPOSE_WITH_COMPLETABLE(x -> method_that_returns_completable(x))
                .map(x -> x + 1) // i still need x here

如何实现？

Answer 1

single.flatMap(new Func1<Integer, Single<? extends Integer>>() {
        @Override
        public Single<? extends Integer> call(final Integer integer) {
            return completable.toSingle(new Func0<Integer>() {
                @Override
                public Integer call() {
                    return integer;
                }
            });
        }
    })