Reactive 响应式编程05 Flux源码分析

​Reactor 3 的 subscribe实现​

CoreSubscriber ： 如果订阅者发出的元素请求数量小于或等于0，则请求不会产生onError事件

对于RxJava2的实现，当元素请求数量n小于或等于0时，会产生一个onError事件

​onNext方法实现​​

1.如果已经结束下发，那么采用放弃策略 Operators.onNextDropped()

2.如果往队列中添加元素失败，那么针对这个异常，包装一个错误事件，也就是onOperateError