我正在尝试用rsocket-websocket客户端构建一个聊天前端。我能够使用requestChannel(new Flowable(source...))从前端发送消息,并使用requestChannel(new Flowable.just({metatdata}))接收消息。无法找到rsocket的FlowableProcessor文档。const processor = new FlowableProcessor(
new Flowable(source =&
正如我所理解的,RSocket支持使用encodeCompositeMetadata和encodeRoute路由消息,但是,我不能让服务器接受fireAndForget消息。服务器经常记录以下消息:这是我试图触发的服务器映射: public class MockController {
private static final Logger LOGGER = Logg