Reactor中行为主体（RxJS）的等效物是什么

Question

我精通RxJS，并在Reactor framework（java）方面迈出了第一步。

Reactor中行为主体的等效物是什么？

或者与RxJS相比，Reactor中使用的模式完全不同吗？对于了解RxJS的人来说，有什么好的参考资料可以学习Reactor吗？

Answer 1

行为主题（BehaviorSubject）是一个热门的发布者，我们甚至可以在订阅之前访问发出的最后一个值。

我们有很多方法可以在项目Reactor中创建一个热门出版商。最接近行为主体的是回放处理器。在这里检查。

Reactor参考在这里。

Answer 2

如前所述，ReplayProcess已被弃用。现在似乎该走下沉的路了。我认为这应该像一个初始值为“hello”的BehaviorSubject：

Sinks.Many<String> behaviorSubject = Sinks
            .many() // multiple values are expected to be emitted
            .replay() // replay value(s) for late subscribers
            .latestOrDefault("hello"); // only replay latest value

// --- usage ---
behaviorSubject.tryEmitNext("goodbye");

官方文件提到了这一点，可以在这里查看：

https://projectreactor.io/docs/core/3.4.15/reference/index.html#sinks