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 Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<T>	doInTransaction(ReactiveTransactionStatus<C> status) Invokes the given code passing the ReactiveTransactionStatus.

Method Detail

doInTransaction

org.reactivestreams.Publisher<T> doInTransaction(ReactiveTransactionStatus<C> status)
                                          throws java.lang.Exception

Invokes the given code passing the ReactiveTransactionStatus.

Parameters:

status - The status

Returns:

A publisher that emits the return type

Throws:

java.lang.Exception - If an error occurs, though generally these should be emitted through the returned Publisher