Package io.micronaut.transaction.reactive

Interface ReactiveTransactionOperations<C>

Type Parameters:
C - The connection type
All Known Subinterfaces:
R2dbcReactorTransactionOperations, ReactorReactiveTransactionOperations<C>
All Known Implementing Classes:
AbstractReactorTransactionOperations
public interface ReactiveTransactionOperations<C>
An interface fo reactive transaction management.
Since:
2.2.0

  • Method Details

    • withTransaction

      @NonNull <T> @NonNull org.reactivestreams.Publisher<T> withTransaction(@NonNull @NonNull TransactionDefinition definition, @NonNull @NonNull ReactiveTransactionOperations.TransactionalCallback<C,T> handler)
      Execute the given handler with a new transaction.
      Type Parameters:
      T - The emitted type
      Parameters:
      definition - The definition
      handler - The handler
      Returns:
      A publisher that emits the result type

    • withTransaction

      @NonNull default <T> @NonNull org.reactivestreams.Publisher<T> withTransaction(@NonNull @NonNull ReactiveTransactionOperations.TransactionalCallback<C,T> handler)
      Execute the given handler with a new transaction.
      Type Parameters:
      T - The emitted type
      Parameters:
      handler - The handler
      Returns:
      A publisher that emits the result type

    • managesTransaction

      boolean managesTransaction(@NonNull @NonNull ReactiveTransactionStatus<C> transactionStatus)
      Determine whether the given transaction status refers to a transaction managed by this ReactiveTransactionOperations instance.
      Parameters:
      transactionStatus - The transaction status to verify
      Returns:
      true if the transaction is managed (i.e. created/supplied) by this operations instance
      Since:
      5.0