public static <T> FlowableTransformer<T,T> txFlowableTransformer(SQLConnection sqlConnection)
FlowableTransformer
decorating a Flowable
with transaction management for a given SQLConnection
.
If the upstream Flowable
completes (onComplete), the transaction is committed.
If the upstream Flowable
emits an error (onError), the transaction is rollbacked.
Eventually, the given SQLConnection
is put back in autocommit mode.
T
- the type of the items emitted by the upstream Flowable
sqlConnection
- the SQLConnection
used for database operations and transaction managementFlowableTransformer
decorating a Flowable
with transaction managementpublic static <T> Flowable<T> inTransactionFlowable(SQLClient client, java.util.function.Function<SQLConnection,Flowable<T>> sourceSupplier)
Flowable
from SQLConnection
operations executed inside a transaction.T
- the type of the items emitted by the Flowable
client
- the SQLClient
sourceSupplier
- a user-provided function returning a Flowable
generated by interacting with the given SQLConnection
Flowable
generated from SQLConnection
operations executed inside a transactionpublic static <T> ObservableTransformer<T,T> txObservableTransformer(SQLConnection sqlConnection)
ObservableTransformer
decorating an Observable
with transaction management for a given SQLConnection
.
If the upstream Observable
completes (onComplete), the transaction is committed.
If the upstream Observable
emits an error (onError), the transaction is rollbacked.
Eventually, the given SQLConnection
is put back in autocommit mode.
T
- the type of the items emitted by the upstream Observable
sqlConnection
- the SQLConnection
used for database operations and transaction managementObservableTransformer
decorating an Observable
with transaction managementpublic static <T> Observable<T> inTransactionObservable(SQLClient client, java.util.function.Function<SQLConnection,Observable<T>> sourceSupplier)
Observable
from SQLConnection
operations executed inside a transaction.T
- the type of the items emitted by the Observable
client
- the SQLClient
sourceSupplier
- a user-provided function returning a Observable
generated by interacting with the given SQLConnection
Observable
generated from SQLConnection
operations executed inside a transactionpublic static <T> SingleTransformer<T,T> txSingleTransformer(SQLConnection sqlConnection)
SingleTransformer
decorating a Single
with transaction management for a given SQLConnection
.
If the upstream Single
emits a value (onSuccess), the transaction is committed.
If the upstream Single
emits an error (onError), the transaction is rollbacked.
Eventually, the given SQLConnection
is put back in autocommit mode.
T
- the type of the item emitted by the upstream Single
sqlConnection
- the SQLConnection
used for database operations and transaction managementSingleTransformer
decorating a Single
with transaction managementpublic static <T> Single<T> inTransactionSingle(SQLClient client, java.util.function.Function<SQLConnection,Single<T>> sourceSupplier)
Single
from SQLConnection
operations executed inside a transaction.T
- the type of the item emitted by the Single
client
- the SQLClient
sourceSupplier
- a user-provided function returning a Single
generated by interacting with the given SQLConnection
Single
generated from SQLConnection
operations executed inside a transactionpublic static <T> MaybeTransformer<T,T> txMaybeTransformer(SQLConnection sqlConnection)
MaybeTransformer
decorating a Maybe
with transaction management for a given SQLConnection
.
If the upstream Maybe
emits a value (onSuccess) or completes (onComplete), the transaction is committed.
If the upstream Maybe
emits an error (onError), the transaction is rollbacked.
Eventually, the given SQLConnection
is put back in autocommit mode.
T
- the type of the item emitted by the upstream Maybe
sqlConnection
- the SQLConnection
used for database operations and transaction managementMaybeTransformer
decorating a Maybe
with transaction managementpublic static <T> Maybe<T> inTransactionMaybe(SQLClient client, java.util.function.Function<SQLConnection,Maybe<T>> sourceSupplier)
Maybe
from SQLConnection
operations executed inside a transaction.T
- the type of the item emitted by the Maybe
client
- the SQLClient
sourceSupplier
- a user-provided function returning a Maybe
generated by interacting with the given SQLConnection
Maybe
generated from SQLConnection
operations executed inside a transactionpublic static CompletableTransformer txCompletableTransformer(SQLConnection sqlConnection)
CompletableTransformer
decorating a Completable
with transaction management for a given SQLConnection
.
If the upstream Completable
completes (onComplete), the transaction is committed.
If the upstream Completable
emits an error (onError), the transaction is rollbacked.
Eventually, the given SQLConnection
is put back in autocommit mode.
sqlConnection
- the SQLConnection
used for database operations and transaction managementCompletableTransformer
decorating a Completable
with transaction managementpublic static Completable inTransactionCompletable(SQLClient client, java.util.function.Function<SQLConnection,Completable> sourceSupplier)
Completable
from SQLConnection
operations executed inside a transaction.client
- the SQLClient
sourceSupplier
- a user-provided function returning a Completable
generated by interacting with the given SQLConnection
Completable
generated from SQLConnection
operations executed inside a transactionpublic static <T> Flowable<T> usingConnectionFlowable(SQLClient client, java.util.function.Function<SQLConnection,Flowable<T>> sourceSupplier)
Flowable
from SQLConnection
operations.T
- the type of the items emitted by the Flowable
client
- the SQLClient
sourceSupplier
- a user-provided function returning a Flowable
generated by interacting with the given SQLConnection
Flowable
generated from SQLConnection
operationspublic static <T> Observable<T> usingConnectionObservable(SQLClient client, java.util.function.Function<SQLConnection,Observable<T>> sourceSupplier)
Observable
from SQLConnection
operations.T
- the type of the items emitted by the Observable
client
- the SQLClient
sourceSupplier
- a user-provided function returning a Observable
generated by interacting with the given SQLConnection
Observable
generated from SQLConnection
operationspublic static <T> Single<T> usingConnectionSingle(SQLClient client, java.util.function.Function<SQLConnection,Single<T>> sourceSupplier)
Single
from SQLConnection
operations.T
- the type of the item emitted by the Single
client
- the SQLClient
sourceSupplier
- a user-provided function returning a Single
generated by interacting with the given SQLConnection
Single
generated from SQLConnection
operationspublic static <T> Maybe<T> usingConnectionMaybe(SQLClient client, java.util.function.Function<SQLConnection,Maybe<T>> sourceSupplier)
Maybe
from SQLConnection
operations.T
- the type of the item emitted by the Maybe
client
- the SQLClient
sourceSupplier
- a user-provided function returning a Maybe
generated by interacting with the given SQLConnection
Maybe
generated from SQLConnection
operationspublic static Completable usingConnectionCompletable(SQLClient client, java.util.function.Function<SQLConnection,Completable> sourceSupplier)
Completable
from SQLConnection
operations.client
- the SQLClient
sourceSupplier
- a user-provided function returning a Completable
generated by interacting with the given SQLConnection
Completable
generated from SQLConnection
operationsCopyright © 2022 Eclipse. All rights reserved.