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 FlowablesqlConnection - 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 Flowableclient - the SQLClientsourceSupplier - a user-provided function returning a Flowable generated by interacting with the given SQLConnectionFlowable 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 ObservablesqlConnection - 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 Observableclient - the SQLClientsourceSupplier - a user-provided function returning a Observable generated by interacting with the given SQLConnectionObservable 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 SinglesqlConnection - 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 Singleclient - the SQLClientsourceSupplier - a user-provided function returning a Single generated by interacting with the given SQLConnectionSingle 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 MaybesqlConnection - 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 Maybeclient - the SQLClientsourceSupplier - a user-provided function returning a Maybe generated by interacting with the given SQLConnectionMaybe 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 SQLClientsourceSupplier - a user-provided function returning a Completable generated by interacting with the given SQLConnectionCompletable 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 Flowableclient - the SQLClientsourceSupplier - a user-provided function returning a Flowable generated by interacting with the given SQLConnectionFlowable 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 Observableclient - the SQLClientsourceSupplier - a user-provided function returning a Observable generated by interacting with the given SQLConnectionObservable 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 Singleclient - the SQLClientsourceSupplier - a user-provided function returning a Single generated by interacting with the given SQLConnectionSingle 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 Maybeclient - the SQLClientsourceSupplier - a user-provided function returning a Maybe generated by interacting with the given SQLConnectionMaybe generated from SQLConnection operationspublic static Completable usingConnectionCompletable(SQLClient client, java.util.function.Function<SQLConnection,Completable> sourceSupplier)
Completable from SQLConnection operations.client - the SQLClientsourceSupplier - a user-provided function returning a Completable generated by interacting with the given SQLConnectionCompletable generated from SQLConnection operationsCopyright © 2021 Eclipse. All rights reserved.