我已经编写了Subscriber的代码,它保留了使用SubmissionPublisher时收到的项目的数量。但是,当我将值从Processor (扩展SubmissionPublisher)传递到下面的Subscriber时,不会将任何输出输出到控制台。添加最小可重现示例 public class NewClass { SubmissionPublisher<Integer> publisher
每隔一段时间,我就会检索带有特定查询的tweet。这些tweet必须传递给计算和操作这些tweet的服务。因此,这些服务是订阅我的出版商。因此,publisher.hasSubscribers()返回true。但是提交或提供函数不会调用我的订阅者的onNext。因此,作为一个“修复”,我循环通过我的订阅者并自己调用它。但情况不应该是这样。 public TwitterStreamer(Executor executor, int maxBufferCapacity, long period, TimeUnit unit, String searchQuery){