java - rxJava : composing single with completable and return single

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;
                }
            });
        }
    })