RxJava可观测单显示当前线程

Question

我试图理解可观察性是如何工作的，我想展示当前线程以更好地理解。整个应用程序是用java 8构建的，并使用lambda表达式。没有太多的经验，我发现用这样的表达式显示当前线程有一些困难：

.subscribeOn(Schedulers.io())                          
.observeOn(Schedulers.computation())
.flatMap(..... -> {

我喜欢这样写：

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

但是我找不到一种方法来做它作为订阅（Schedulers.io（））和观察（Schedulers.computation（））返回和单一，没有办法把这样的东西：

.subscribeOn(Schedulers.io())
.log.info("Current Thread:", Thread.currentThread().name)
.observeOn(Schedulers.computation())
.log.info("Current Thread:", Thread.currentThread().name)
.flatMap(..... -> {

谢谢

Answer 1

您正在尝试记录当前线程，对吗？

只需使用map进行日志并返回相同的值：

.subscribeOn(Schedulers.io())
.map(it -> {
    log.info("Current Thread:", Thread.currentThread().name)
    return it;
})
.observeOn(Schedulers.computation())
.map(it -> {
    log.info("Current Thread:", Thread.currentThread().name)
    return it;
})
.flatMap(..... -> {