- .flatMap(existing -> text.equals(existing.getMessageText())
- ? Mono.just(existing)
- : Mono.error(() -> new MessageMutationException(existing, text)))
+ .handle((Message existing, SynchronousSink<Message> sink) ->
+ {
+ if (existing.getMessageText().equals(text))
+ {
+ sink.next(existing);
+ }
+ else
+ {
+ sink.error(new MessageMutationException(existing, text));
+ }
+ })