- default void writeChatRoomData(
- UUID chatRoomId,
- Flux<Message> messageFlux,
- ChatRoomWrittenSuccessCallback successCallback,
- ChatRoomWrittenFailureCallback failureCallback)
- {
- writeChatRoomData(
- chatRoomId,
- messageFlux
- .doOnComplete(() -> successCallback.accept(chatRoomId))
- .doOnError(throwable -> failureCallback.accept(chatRoomId, throwable)));
- }
- void writeChatRoomData(UUID chatRoomId, Flux<Message> messageFlux);