删除多个订阅并将其保留为单个流

Question

我有以下方法，这是预期的工作。

但是有没有办法修改它，这样我就不必单独订阅网络客户的电话了

取而代之的是让它成为流量的一部分，并且只从某个订户那里订阅一次？

请注意，这最终必须返回一个可观察的

Observable<Integer> observable = Observable.just(1)
        .delay(5, TimeUnit.MILLISECONDS)
        .compose(obs -> {
            webClient.putAbs("url")
                    .rxSend()
                    .doOnSubscribe(() -> System.out.println("Subbing to client")) // to be removed with solution
                    .subscribe(); // I don't want to have to do a sub here. 
            return obs;
        })
        .doOnSubscribe(() -> System.out.println("the only single sub i want to have"));

一些外部订户将执行以下操作。

可见。订阅（）；

我希望这能触发整个流程，这也会触发webclient的调用，而不是像上面那样单独调用它。

这可能吗？

因此，寻找类似以下内容的内容，而不是单独订阅webClient。

尝试通过平面地图和撰写，但无法实现它。

（以下语法错误。这只是粗略地说明我在寻找什么）。

Observable<Integer> observable = Observable.just(1)
        .delay(5, TimeUnit.MILLISECONDS)
        .compose(obs -> webClient.putAbs(""))
        .rxSend()
        .toObservable();

感谢您的指导。谢谢

Answer 1

这应该行得通：

Observable<Integer> observable = Observable.just(1)
            .delay(5, TimeUnit.MILLISECONDS)
            .flatMap(obs -> webClient.putAbs("url").rxSend().map(a -> obs));

。flatMap（）急切地订阅内部webClient调用。