在这种情况下，Project Reactor 会做什么？
What will project reactor do in this scenario?
在交易量非常低的环境下，比如我们的一些测试环境，如果订阅者请求 N 个新项目工作，但发布者当前少于，项目反应器 类 会做什么N 个新项目要发送。发布者是否会 (1) 立即发送少于 N 个新项目，(2) 等到它有 N 个新项目要发送，或者 (3) 等到可配置的超时后再发送少于 N 个新项目？我正在尝试解决一个问题，在这些非常低容量的环境之一中，这让我相信发布者方面存在问题，即使订阅者应该定期请求批量工作。
如果发布商可以部分回答请求，则必须发送这些 x < N 项。它还必须记住，剩余需求当前处于 y = N-x，并在这些元素变得可用时发送这些元素 ，即使订阅者没有进一步请求。
如果发布者知道它无法满足全部需求，因为它使用有限的数据集，那么它必须在发出它可以发出的内容后用 onComplete 尽早完成序列.
在交易量非常低的环境下，比如我们的一些测试环境，如果订阅者请求 N 个新项目工作，但发布者当前少于，项目反应器 类 会做什么N 个新项目要发送。发布者是否会 (1) 立即发送少于 N 个新项目，(2) 等到它有 N 个新项目要发送，或者 (3) 等到可配置的超时后再发送少于 N 个新项目？我正在尝试解决一个问题，在这些非常低容量的环境之一中，这让我相信发布者方面存在问题，即使订阅者应该定期请求批量工作。
如果发布商可以部分回答请求，则必须发送这些 x < N 项。它还必须记住，剩余需求当前处于 y = N-x，并在这些元素变得可用时发送这些元素 ，即使订阅者没有进一步请求。
如果发布者知道它无法满足全部需求，因为它使用有限的数据集，那么它必须在发出它可以发出的内容后用 onComplete 尽早完成序列.