java - 具有延迟可观察性的 SwitchMap

Question

 Observable
     .interval(2, TimeUnit.SECONDS)
     .switchMap(integer -> 
        Observable
                 .just(integer * 2) 
                 .delay(5,SECONDS))
     .subscribe(integer -> { System.out.println(integer);});

据我所知，在 switch map 之后我们应该订阅最后创建的 observable，所以我希望 20 秒后输出“8”，但它会永远等待

Answer 1

switchMap()操作符的操作如下:

1. 接收上游发出的值
2. 使用发出的值调用函数参数，该值必须是可观察的
3. 订阅 observable
4. 发出来自该可观察对象的任何项目
5. 当上游发出新项目时，取消订阅第 3 步中的可观察对象，然后从第 2 步开始。

结果是延迟的 observable 永远不会发出任何东西，因为它每 2 秒就会被取消订阅。

您将需要使用 flatMap() 运算符，它不会取消订阅每个发出的值。