RxJava Observable Single 显示当前线程

Question

我试图了解 observable 是如何工作的，我想展示当前线程以获得更好的理解。整个应用程序使用 java 8 构建并使用 lambda 表达式。没有太多的经验，我发现在用这样的表达式显示我当前的线程时遇到了一些麻烦：

.subscribeOn(Schedulers.io())                          

.observeOn(Schedulers.computation())

.flatMap(..... -> {

我喜欢这样写：

log.info("Current Thread:", Thread.currentThread().name)

但是我找不到一种方法来做到这一点，因为 subscribeOn(Schedulers.io()) 和 observeOn(Schedulers.computation()) 返回和 Single 并且没有办法放置这样的东西：

.subscribeOn(Schedulers.io())

.log.info("Current Thread:", Thread.currentThread().name)

.observeOn(Schedulers.computation())

.log.info("Current Thread:", Thread.currentThread().name)

.flatMap(..... -> {