io.micronaut.transaction.reactive

Interface ReactiveTransactionOperations<C>

Type Parameters:

C - The connection type

All Known Subinterfaces:

R2dbcOperations

All Known Implementing Classes:

DefaultR2dbcRepositoryOperations

public interface ReactiveTransactionOperations<C>

An interface fo reactive transaction management.

Since:

2.2.0

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ReactiveTransactionOperations.TransactionalCallback<C,T> A transactional callback interface.

Method Summary

Modifier and Type	Method and Description
default <T> org.reactivestreams.Publisher<T>	withTransaction(ReactiveTransactionOperations.TransactionalCallback<C,T> handler) Execute the given handler with a new transaction.
<T> org.reactivestreams.Publisher<T>	withTransaction(TransactionDefinition definition, ReactiveTransactionOperations.TransactionalCallback<C,T> handler) Execute the given handler with a new transaction.

Method Detail

withTransaction

@NonNull
<T> org.reactivestreams.Publisher<T> withTransaction(@NonNull
                                                              TransactionDefinition definition,
                                                              @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> org.reactivestreams.Publisher<T> withTransaction(@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