Skip to content

Commit

Permalink
Avoid deprecated usingWhen method in Reactor 3.3
Browse files Browse the repository at this point in the history
Closes gh-23562
  • Loading branch information
jhoeller committed Sep 20, 2019
1 parent 393a81d commit a48c13a
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -80,7 +80,7 @@ public <T> Mono<T> transactional(Mono<T> mono) {
// Need re-wrapping of ReactiveTransaction until we get hold of the exception
// through usingWhen.
return status.flatMap(it -> Mono.usingWhen(Mono.just(it), ignore -> mono,
this.transactionManager::commit, s -> Mono.empty())
this.transactionManager::commit, (res, err) -> Mono.empty(), s -> Mono.empty())
.onErrorResume(ex -> rollbackOnException(it, ex).then(Mono.error(ex))));
})
.subscriberContext(TransactionContextManager.getOrCreateContext())
Expand Down

0 comments on commit a48c13a

Please sign in to comment.