Interface ReactiveTransactionOperations.TransactionalCallback<C,T>

Type Parameters:
C - The connection type
T - The emitted type
Enclosing interface:
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.
      status - The status
      A publisher that emits the return type
      Exception - If an error occurs, though generally these should be emitted through the returned Publisher