我试图了解 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(..... -> {
添加回答
举报
0/150
提交
取消