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.

    public static interface ReactiveTransactionOperations.TransactionalCallback<C,​T>
    A transactional callback interface.
    • Method Detail

      • doInTransaction

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