项目reactor中RxJava PublishSubject的等价物是什么?我需要Flux,我可以在上面调用next()
方法。
它们被称为Sinks
。参见反应器参考:https://projectreactor.io/docs/core/release/reference/#processors