}
@Override
- public void writeChatRoomData(UUID chatRoomId, Flux<Message> messageFlux) {}
+ public void writeChatRoomData(
+ UUID chatRoomId,
+ Flux<Message> messageFlux,
+ SuccessCallback successCallback,
+ FailureCallback failureCallback
+ )
+ {
+ successCallback.accept(chatRoomId);
+ }
@Override
public Flux<Message> readChatRoomData(UUID chatRoomId)