Package io.micronaut.transaction.reactive

Interface ReactiveTransactionOperations<C>

Type Parameters:

C - The connection type

All Known Subinterfaces:

R2dbcReactorTransactionOperations, ReactorReactiveTransactionOperations<C>

All Known Implementing Classes:

AbstractReactorTransactionOperations

public interface ReactiveTransactionOperations<C>

An interface fo reactive transaction management.

Since:

2.2.0

Nested Class Summary

Nested Classes

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

Method Summary

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

Method Details

withTransaction

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