为了账号安全,请及时绑定邮箱和手机立即绑定

RxJava Observable Single 显示当前线程

RxJava Observable Single 显示当前线程

暮色呼如 2021-09-29 17:27:32
我试图了解 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(..... -> {
查看完整描述

1 回答

  • 1 回答
  • 0 关注
  • 213 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信