我正在尝试实现 java 反应流（观察者设计模式）。
我利用了可用的样本。我向订阅者发送值没有问题，但我不能让订阅者向发布者发送一个值。有什么办法可以让它在处理它之后返回一个值？
我也很高兴听到任何其他方法。
我试过这个样本https://dzone.com/articles/reactive-streams-in-java-9
我正在使用它进行自动交易。我对每只股票都有一个线程。每个线程都向策略发送消息...一旦策略成功，我希望它将结果发回给我
问问题
133 次