为什么发布者即使在取消后仍会发送新项目？

Question

Subscription#cancel 的文档说

Data may still be sent to meet previously signalled demand after calling cancel.

1. 在哪种情况下，人们会期望发布商继续发送直到满足之前的信号需求？
2. 另外，如果我不想在取消后发送任何新商品，我该怎么办？

Answer 1

除非您正在创建低级运算符或Publishers，否则您不必担心这一点。

在哪种情况下，人们会期望发布者继续发送直到满足先前的信号需求？

主流的 Reactive Streams 库都没有这样做，因为它们最终会停止发送项目。 RxJava 2 和 Reactor 3 对此非常渴望，因此您很可能会在低杠杆异步发出的取消中添加一个额外的项目。 Akka Stream 可能发出的信号不止于此（上次我检查时，它们混合了控制和项目信号，并且每个流的最大同步项目有一个配置设置，这可能导致在取消生效之前发出多个项目）。

另外，如果我不想在取消后发送任何新商品，我该怎么办？

取决于您实现的内容：Publisher 或 Subscriber。

在Publisher 中，最急切的方法是设置volatile boolean cancelled field 和check that every time 你处于某种发射循环中。

在Subscriber 中，您可以在每个onXXX 中检查boolean done field，这样当您从onNext 调用Subscription.cancel() 时，任何后续调用will be ignored。