Reactor 中的BehaviorSubject (RxJS) 相当于什么

Question

我精通 RxJS 并初步使用 Reactor 框架 (java)。

Reactor 中的BehaviorSubject 相当于什么？

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

Answer 1

如前所述，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