diff --git a/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionCallback.java b/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionCallback.java index 37864524dc..5c7cf027e4 100644 --- a/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionCallback.java +++ b/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionCallback.java @@ -16,7 +16,6 @@ package org.springframework.transaction.reactive; -import org.jspecify.annotations.Nullable; import org.reactivestreams.Publisher; import org.springframework.transaction.ReactiveTransaction; @@ -37,7 +36,7 @@ import org.springframework.transaction.ReactiveTransaction; * @see TransactionalOperator */ @FunctionalInterface -public interface TransactionCallback { +public interface TransactionCallback { /** * Gets called by {@link TransactionalOperator} within a transactional context. diff --git a/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionalOperator.java b/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionalOperator.java index 71ca2844ca..97ebc74d8b 100644 --- a/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionalOperator.java +++ b/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionalOperator.java @@ -16,7 +16,6 @@ package org.springframework.transaction.reactive; -import org.jspecify.annotations.Nullable; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; @@ -60,7 +59,7 @@ public interface TransactionalOperator { * @throws TransactionException in case of initialization, rollback, or system errors * @throws RuntimeException if thrown by the TransactionCallback */ - default Flux transactional(Flux flux) { + default Flux transactional(Flux flux) { return execute(it -> flux); } @@ -71,7 +70,7 @@ public interface TransactionalOperator { * @throws TransactionException in case of initialization, rollback, or system errors * @throws RuntimeException if thrown by the TransactionCallback */ - default Mono transactional(Mono mono) { + default Mono transactional(Mono mono) { return execute(it -> mono).singleOrEmpty(); } @@ -86,7 +85,7 @@ public interface TransactionalOperator { * @throws TransactionException in case of initialization, rollback, or system errors * @throws RuntimeException if thrown by the TransactionCallback */ - Flux execute(TransactionCallback action) throws TransactionException; + Flux execute(TransactionCallback action) throws TransactionException; // Static builder methods