{
Logger log = LoggerFactory.getLogger(StorageStrategy.class.getCanonicalName());
- default void write(ChatHomeService chatHomeService)
+ default Flux<ChatRoomInfo> write(ChatHomeService chatHomeService)
{
- writeChatRoomInfo(
+ return writeChatRoomInfo(
chatHomeService
.getChatRoomInfo()
.doOnNext(chatRoomInfo ->
.getChatRoomData(chatRoomInfo.getId())
.flatMapMany(chatRoomData -> chatRoomData.getMessages()),
this::logSuccess,
- this::logFailure)));
+ this::logFailure).subscribe()));
}
Flux<ChatRoomInfo> writeChatRoomInfo(Flux<ChatRoomInfo> chatRoomInfoFlux);