}
@Override
- public void writeChatRoomData(
- UUID chatRoomId,
- Flux<Message> messageFlux,
- SuccessCallback successCallback,
- FailureCallback failureCallback)
+ public void writeChatRoomData(UUID chatRoomId, Flux<Message> messageFlux)
{
messageFlux
.map(message -> MessageTo.from(chatRoomId, message))
- .doOnComplete(() -> successCallback.accept(chatRoomId))
- .doOnError(throwable -> failureCallback.accept(chatRoomId, throwable))
.subscribe(messageTo -> messageRepository.save(messageTo));
}