java - RxJava Observable Single 显示当前线程

Question

我正在尝试了解可观察的工作原理，并且我想显示当前线程以更好地理解。整个应用程序是用 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(..... -> {

谢谢

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(..... -> {