Package io.micronaut.transaction.reactive

Interface ReactiveTransactionOperations<C>

Type Parameters:

C - The connection type

All Known Subinterfaces:

HibernateReactorRepositoryOperations, MongoReactorRepositoryOperations, R2dbcOperations, ReactorReactiveTransactionOperations<C>

All Known Implementing Classes:

DefaultReactiveMongoRepositoryOperations

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> 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 Details

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