RxJS技术问询：concatMap未订阅全部groupBy Observable及控制台无输出问题

问题1：为啥concatMap没订阅所有groupBy生成的Observable？ #

咱们先搞懂concatMap的核心逻辑：它是串行处理内部Observable的选手——必须等当前正在订阅的内部Observable彻底完成（发出complete信号），才会转头去订阅下一个内部Observable。

而groupBy生成的每个分组Observable有个特性：只要你的源Observable还没完成，这个分组Observable就会一直“待命”，等着源发出属于它的新值，不会主动触发complete。

举个很典型的场景：如果你的源是无限流（比如interval(100)不停发数），用groupBy按奇偶分组，那第一个被concatMap盯上的分组（比如奇数分组）会一直等着新的奇数进来，永远不会完成。这时候concatMap就会一直“粘”在这个分组上，根本没机会去订阅后面的偶数分组，自然也就不会处理那些分组里的值。

还有一种少见的情况：如果某个分组Observable在concatMap还没轮到它的时候，就已经完成并被销毁了（比如源是有限流，但分组里没有任何值），concatMap也不会去订阅它，但这种情况一般不会导致你遇到的问题。

问题2：为啥控制台没输出2、4、6这些偶数？ #

这其实是第一个问题的直接后果——你的偶数分组Observable从来没被concatMap订阅过。

举个贴合你场景的例子：假设你用了无限源（比如interval），groupBy把1、3、5分到奇数组，2、4、6分到偶数组。concatMap先订阅奇数组，而奇数组会一直等待新的奇数，永远不会完成，concatMap就一直卡在这儿，根本不会去碰偶数组。那偶数组里的2、4、6自然没机会被输出到控制台。

如果你的源是有限流（比如of(1,2,3,4,5,6)）却还是没输出偶数，那大概率是你给分组Observable加了某种不会完成的操作符（比如repeat），导致第一个分组一直不结束，concatMap没法往下走。

内容的提问来源于stack exchange，提问作者sebastian correa