关于我的套接字反应库工作过程中的问题，有一个很长的背景故事。
socket 库主要基于一个名为Monix（类似 ReactiveX）的响应式库。Monix 具有通过（扩展 Future）类型处理背压的最佳实践，Ack该类型在处理当前消息时发出下一条消息。这是一个很好的机制来保护系统的大消息匆忙。
目前设计，每一个socket连接都是一个Observable（或Stream），Observable在解析TCP/IP网络字节流时会创建一个协议消息，然后将协议消息推送给Subscriber。
问题是 Monix 库只能为每个 Observable 做背压。如果您认为有数千个客户端连接，那么云会有这么多的 Observable 和背压是没有意义的。
那么，如何针对单个 Observable 之外的全局系统，为这样的响应式系统设计背压机制呢？
谢谢