RxJava Observable Single показать текущую тему

Question

Я пытаюсь понять, как работает наблюдаемое, и я хотел бы показать текущую тему, чтобы лучше понять.Все приложение построено на Java 8 и использует лямбда-выражения.Не имея большого опыта в этом, я нахожу некоторые проблемы, чтобы показать мою текущую тему в выражении, подобном этому:

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

Мне нравится помещать что-то вроде этого:

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

НоЯ не смог найти способ сделать это, как завершение процедуры subscribeOn (Schedulers.io ()) и наблюденийOn (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(..... -> {