Package io.micronaut.data.r2dbc.transaction

Interface R2dbcReactorTransactionOperations

All Superinterfaces:

ReactiveTransactionOperations<io.r2dbc.spi.Connection>, ReactorReactiveTransactionOperations<io.r2dbc.spi.Connection>

public interface R2dbcReactorTransactionOperations
extends ReactorReactiveTransactionOperations<io.r2dbc.spi.Connection>

R2DBC transaction operations.

Since:

4.0.0

Author:

Denis Stepanov

Nested Class Summary

Nested classes/interfaces inherited from interface io.micronaut.transaction.reactive.ReactiveTransactionOperations

ReactiveTransactionOperations.TransactionalCallback<C,T>

Method Summary

Modifier and Type	Method	Description
default <T> @NonNull org.reactivestreams.Publisher<T>	withTransaction(@NonNull ReactiveTransactionStatus<io.r2dbc.spi.Connection> status, @NonNull ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)	Execute the given handler with an existing transaction status.
<T> @NonNull org.reactivestreams.Publisher<T>	withTransaction(@NonNull ReactiveTransactionStatus<io.r2dbc.spi.Connection> status, @NonNull TransactionDefinition definition, @NonNull ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)	Execute the given handler with an existing transaction status.

Methods inherited from interface io.micronaut.transaction.reactive.ReactorReactiveTransactionOperations

findTransactionStatus, getTransactionDefinition, getTransactionStatus, withTransaction, withTransaction, withTransactionFlux, withTransactionFlux, withTransactionMono, withTransactionMono

Method Details

withTransaction

@NonNull
<T> @NonNull org.reactivestreams.Publisher<T> withTransaction(@NonNull
 @NonNull ReactiveTransactionStatus<io.r2dbc.spi.Connection> status,
 @NonNull
 @NonNull TransactionDefinition definition,
 @NonNull
 @NonNull ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)

Execute the given handler with an existing transaction status.

Type Parameters:

T - The emitted type

Parameters:

status - An existing in progress transaction status

definition - The transaction definition

handler - The handler

Returns:

A publisher that emits the result type

withTransaction

@NonNull
default <T>
@NonNull org.reactivestreams.Publisher<T> withTransaction(@NonNull
 @NonNull ReactiveTransactionStatus<io.r2dbc.spi.Connection> status,
 @NonNull
 @NonNull ReactiveTransactionOperations.TransactionalCallback<io.r2dbc.spi.Connection,T> handler)

Execute the given handler with an existing transaction status.

Type Parameters:

T - The emitted type

Parameters:

status - An existing in progress transaction status

handler - The handler

Returns:

A publisher that emits the result type