Observable
.interval(2, TimeUnit.SECONDS)
.switchMap(integer ->
Observable
.just(integer * 2)
.delay(5,SECONDS))
.subscribe(integer -> { System.out.println(integer);});
据我了解，切换映射后，我们应该订阅上一个创建的可观察对象，因此我希望20秒后输出“ 8”，但它将永远等待
操作switchMap()员的操作如下：
结果是延迟的可观测对象将永远不会发出任何东西，因为它将每2秒退订一次。
您将需要使用flatMap()运算符，而该运算符不会取消订阅每个发出的值。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句