关于webflux reactive存储库的小问题,特别是关于Flux saveAll(Iterable Var1)和Flux saveAll(Publisher Var1)的方法; 为了进行比较,我写了以下内容the mono and map it to a saveAllAndConvertToResponse method (see next method)
Mono<QuestionResponse).thenReturn
以下是设想情况:
我创建了一个反应堆kafka接收机SimpleUrlHandlerMappingURL 从卡夫卡接收器中消耗的数据被发布到一个starter-tomcat上,使用SimpleUrlHandlerMappingURL模式是api/v1/ws/{ ID },并且我希望基于URI中使用的不同ID创建多个WebSocketSession,这些ID由单个WebSocketHanlder管理,这实际上正在发生,但是当来自卡夫卡接收器的数据被发布时,但仍然将来自kafka