这个t就是下游流的对象，当数据到来的时候会先进入MergeObserve里的onNext

 在这个里面获取到了当前flatmap对应的流

 在subscribeInner 新建了InnerObserver 并且让当前的流进行监听

 在InnerObserver onNext，也就是当前flatmap对应的流发射数据的时候发起tryEmit

 先进行cas，失败的存入对列，如果获取到了锁就发射，如果没有获取到锁就等待发射

 这个actual是谁？

 就是下游的流，那么如同rxjava图解里的，flatmap会把当前流的数据包装成多个被观察者，然后进行发射数据

如果异步发射集合的话可能会导致内存过高甚至OOM，这时就需要切片进行发射，防止内存过高

 

相关阅读

评论可见，请评论后查看内容，谢谢！！！
 您阅读本篇文章共花了：