public interface RxConnectionFactory
extends io.r2dbc.spi.ConnectionFactory
Modifier and Type | Interface and Description |
---|---|
static interface |
RxConnectionFactory.RxConnectionFunction<T>
Function applied with a connection.
|
Modifier and Type | Method and Description |
---|---|
io.reactivex.Flowable<? extends RxConnection> |
create()
Creates a new
RxConnection . |
<T> io.reactivex.Flowable<T> |
withConnection(RxConnectionFactory.RxConnectionFunction<T> publisherFunction)
Apply the given function closing the connection on termination.
|
<T> io.reactivex.Flowable<T> |
withTransaction(RxConnectionFactory.RxConnectionFunction<T> publisherFunction)
Apply given function within a context of a transaction, rolling back if an error occurs and committing if not.
|
@NonNull io.reactivex.Flowable<? extends RxConnection> create()
RxConnection
.create
in interface io.r2dbc.spi.ConnectionFactory
RxConnection
@NonNull <T> io.reactivex.Flowable<T> withConnection(@NonNull RxConnectionFactory.RxConnectionFunction<T> publisherFunction)
T
- The return typepublisherFunction
- The publisher function@NonNull <T> io.reactivex.Flowable<T> withTransaction(@NonNull RxConnectionFactory.RxConnectionFunction<T> publisherFunction)
T
- The return typepublisherFunction
- The publisher function