very minor javadoc fixes

Author: gavinking

hibernate-reactive-core/src/main/java/org/hibernate/reactive/mutiny/Mutiny.java

@@ -2030,7 +2030,7 @@ interface SessionFactory extends AutoCloseable {
 
 
 		/**
-		 * Perform work using a {@link Session reactive session}.
+		 * Perform work using a {@linkplain Session reactive session}.
 		 * <p>
 		 * <il>
 		 * <li>If there is already a session associated with the current
@@ -2049,7 +2049,7 @@ interface SessionFactory extends AutoCloseable {
 		<T> Uni<T> withSession(Function<Session, Uni<T>> work);
 
 		/**
-		 * Perform work using a {@link Session reactive session} for
+		 * Perform work using a {@linkplain Session reactive session} for
 		 * a specified tenant.
 		 * <p>
 		 * <il>
@@ -2069,12 +2069,12 @@ interface SessionFactory extends AutoCloseable {
 		<T> Uni<T> withSession(String tenantId, Function<Session, Uni<T>> work);
 
 		/**
-		 * Perform work using a {@link Session reactive session} within an
-		 * associated {@link Transaction transaction}.
+		 * Perform work using a {@linkplain Session reactive session}
+		 * within an associated {@link Transaction transaction}.
 		 * <p>
 		 * <il>
-		 * <li>If there is already a session associated with the
-		 * current reactive stream, then the work will be executed using that
+		 * <li>If there is already a session associated with the current
+		 * reactive stream, then the work will be executed using that
 		 * session.
 		 * <li>Otherwise, if there is no session associated with the
 		 * current stream, a new session will be created.
@@ -2092,12 +2092,12 @@ interface SessionFactory extends AutoCloseable {
 		<T> Uni<T> withTransaction(BiFunction<Session, Transaction, Uni<T>> work);
 
 		/**
-		 * Perform work using a {@link Session reactive session} within an
-		 * associated transaction.
+		 * Perform work using a {@linkplain Session reactive session}
+		 * within an associated transaction.
 		 * <p>
 		 * <il>
-		 * <li>If there is already a session associated with the
-		 * current reactive stream, then the work will be executed using that
+		 * <li>If there is already a session associated with the current
+		 * reactive stream, then the work will be executed using that
 		 * session.
 		 * <li>Otherwise, if there is no session associated with the
 		 * current stream, a new session will be created.
@@ -2117,8 +2117,8 @@ default <T> Uni<T> withTransaction(Function<Session, Uni<T>> work) {
 		}
 
 		/**
-		 * Perform work using a {@link StatelessSession reactive session} within an
-		 * associated {@link Transaction transaction}.
+		 * Perform work using a {@linkplain StatelessSession reactive session}
+		 * within an associated {@link Transaction transaction}.
 		 * <p>
 		 * <il>
 		 * <li>If there is already a stateless session associated with the
@@ -2128,10 +2128,11 @@ default <T> Uni<T> withTransaction(Function<Session, Uni<T>> work) {
 		 * current stream, a new stateless session will be created.
 		 * </il>
 		 * <p>
-		 * The session will be closed automatically and the transaction committed automatically.
+		 * The session will be closed automatically and the transaction committed
+		 * automatically.
 		 *
-		 * @param work a function which accepts the stateless session and returns
-		 * the result of the work as a {@link Uni}.
+		 * @param work a function which accepts the stateless session and
+		 * returns the result of the work as a {@link Uni}.
 		 *
 		 * @see #withStatelessSession(Function)
 		 * @see StatelessSession#withTransaction(Function)
@@ -2141,8 +2142,8 @@ default <T> Uni<T> withStatelessTransaction(Function<StatelessSession, Uni<T>> w
 		}
 
 		/**
-		 * Perform work using a {@link StatelessSession reactive session} within an
-		 * associated {@link Transaction transaction}.
+		 * Perform work using a {@linkplain StatelessSession reactive session}
+		 * within an associated {@link Transaction transaction}.
 		 * <p>
 		 * <il>
 		 * <li>If there is already a stateless session associated with the
@@ -2152,7 +2153,8 @@ default <T> Uni<T> withStatelessTransaction(Function<StatelessSession, Uni<T>> w
 		 * current stream, a new stateless session will be created.
 		 * </il>
 		 * <p>
-		 * The session will be closed automatically and the transaction committed automatically.
+		 * The session will be closed automatically and the transaction committed
+		 * automatically.
 		 *
 		 * @param work a function which accepts the stateless session and returns
 		 * the result of the work as a {@link Uni}.
@@ -2163,7 +2165,7 @@ default <T> Uni<T> withStatelessTransaction(Function<StatelessSession, Uni<T>> w
 		<T> Uni<T> withStatelessTransaction(BiFunction<StatelessSession, Transaction, Uni<T>> work);
 
 		/**
-		 * Perform work using a {@link StatelessSession stateless session}.
+		 * Perform work using a {@linkplain StatelessSession stateless session}.
 		 * <p>
 		 * <il>
 		 * <li>If there is already a stateless session associated with the
@@ -2181,14 +2183,15 @@ default <T> Uni<T> withStatelessTransaction(Function<StatelessSession, Uni<T>> w
 		<T> Uni<T> withStatelessSession(Function<StatelessSession, Uni<T>> work);
 
 		/**
-		 * Perform work using a {@link StatelessSession stateless session}.
+		 * Perform work using a {@linkplain StatelessSession stateless session}.
 		 * <p>
 		 * <il>
 		 * <li>If there is already a stateless session associated with the
-		 * current reactive stream and given tenant id, then the work will be executed using that
-		 * session.
+		 * current reactive stream and given tenant id, then the work will be
+		 * executed using that session.
 		 * <li>Otherwise, if there is no stateless session associated with the
-		 * current stream and given tenant id, a new stateless session will be created.
+		 * current stream and given tenant id, a new stateless session will be
+		 * created.
 		 * </il>
 		 * <p>
 		 * The session will be closed automatically.
@@ -2200,15 +2203,16 @@ default <T> Uni<T> withStatelessTransaction(Function<StatelessSession, Uni<T>> w
 		<T> Uni<T> withStatelessSession(String tenantId, Function<StatelessSession, Uni<T>> work);
 
 		/**
-		 * Perform work using a {@link Session reactive session} for a
+		 * Perform work using a {@linkplain Session reactive session} for a
 		 * specified tenant within an associated {@link Transaction transaction}.
 		 * <p>
 		 * <il>
 		 * <li>If there is already a session associated with the
-		 * current reactive stream and given tenant id, then the work will be executed using that
-		 * session.
+		 * current reactive stream and given tenant id, then the work
+		 * will be executed using that session.
 		 * <li>Otherwise, if there is no session associated with the
-		 * current stream and given tenant id, a new stateless session will be created.
+		 * current stream and given tenant id, a new stateless session
+		 * will be created.
 		 * </il>
 		 * <p>
 		 * The session will be {@link Session#flush() flushed} and closed
@@ -2224,18 +2228,20 @@ default <T> Uni<T> withStatelessTransaction(Function<StatelessSession, Uni<T>> w
 		<T> Uni<T> withTransaction(String tenantId, BiFunction<Session, Transaction, Uni<T>> work);
 
 		/**
-		 * Perform work using a {@link StatelessSession reactive session} for a
-		 * specified tenant within an associated {@link Transaction transaction}.
+		 * Perform work using a {@linkplain StatelessSession reactive session} for
+		 * a specified tenant within an associated {@link Transaction transaction}.
 		 * <p>
 		 * <il>
 		 * <li>If there is already a stateless session associated with the
-		 * current reactive stream and given tenant id, then the work will be executed using that
-		 * session.
+		 * current reactive stream and given tenant id, then the work will be
+		 * executed using that session.
 		 * <li>Otherwise, if there is no stateless session associated with the
-		 * current stream and given tenant id, a new stateless session will be created.
+		 * current stream and given tenant id, a new stateless session will be
+		 * created.
 		 * </il>
 		 * <p>
-		 * The session will be closed automatically and the transaction committed automatically.
+		 * The session will be closed automatically and the transaction committed
+		 * automatically.
 		 *
 		 * @param tenantId the id of the tenant
 		 * @param work a function which accepts the stateless session and returns

hibernate-reactive-core/src/main/java/org/hibernate/reactive/mutiny/impl/MutinyStatelessSessionImpl.java

@@ -300,6 +300,10 @@ public Mutiny.Transaction currentTransaction() {
 	private class Transaction<T> implements Mutiny.Transaction {
 		boolean rollback;
 
+		/**
+		 * Execute the given work in a new transaction. Called only
+		 * when no existing transaction was active.
+		 */
 		Uni<T> execute(Function<Mutiny.Transaction, Uni<T>> work) {
 			currentTransaction = this;
 			return begin()
@@ -308,14 +312,15 @@ Uni<T> execute(Function<Mutiny.Transaction, Uni<T>> work) {
 		}
 
 		/**
-		 * Run the code assuming that a transaction has already started so that we can
-		 * differentiate an error starting a transaction (and therefore doesn't need to rollback)
-		 * and an error thrown by the work.
+		 * Run the code assuming that a transaction has already started
+		 * so that we can differentiate an error starting a transaction
+		 * (which therefore does not need to trigger rollback) from an
+		 * error thrown by the work (which does).
 		 */
 		Uni<T> executeInTransaction(Function<Mutiny.Transaction, Uni<T>> work) {
 			return Uni.createFrom().deferred( () -> work.apply( this ) )
 					// in the case of an exception or cancellation
-					// we need to rollback the transaction
+					// we need to roll back the transaction
 					.onFailure().call( this::rollback )
 					.onCancellation().call( this::rollback )
 					// finally, when there was no exception,