RxJava 源码解读之 ConcatMap

ConcatMap是RxJava中的一个操作符，它的作用是将发射的每个数据项转换成一个Observable，然后将这些Observable发射的数据合并成一个Observable并发射出去。和FlatMap操作符类似，不同之处在于它发射数据的顺序是有序的。

在实现中，ConcatMap操作符通过一个内部的Observable来实现数据的按序发射。当它接收到一个新的数据项时，它会将这个数据项转换成一个Observable，并将这个Observable添加到内部的Observable队列中。然后，它会订阅这个内部的Observable，并将它发射的数据添加到最终的Observable队列中。当内部的Observable发射完数据后，它会从队列中移除，并订阅下一个内部的Observable。这样就保证了发射数据的顺序是有序的。

具体实现中，ConcatMap操作符使用了一个ConcatMapObserver来管理内部的Observable队列，并使用了一个InnerObserver来处理内部的Observable发射的数据。

总的来说，ConcatMap操作符是一个非常有用的操作符，它可以保证数据的有序性，并且可以将一个Observable中的每个数据项转换成另一个Observable再发射出去，这样就可以对数据进行更加灵活的处理。