Package io.micronaut.transaction.reactive

Interface ReactiveTransactionOperations.TransactionalCallback<C,T>

Type Parameters:
C - The connection type
T - The emitted type
Enclosing interface:
ReactiveTransactionOperations<C>
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface ReactiveTransactionOperations.TransactionalCallback<C,T>
A transactional callback interface.

  • Method Details

    • doInTransaction

      org.reactivestreams.Publisher<T> doInTransaction(ReactiveTransactionStatus<C> status) throws Exception
      Invokes the given code passing the ReactiveTransactionStatus.
      Parameters:
      status - The status
      Returns:
      A publisher that emits the return type
      Throws:
      Exception - If an error occurs, though generally these should be emitted through the returned Publisher