public class InTransactionObservable<T> extends Object implements ObservableTransformer<T,T>
| Constructor and Description |
|---|
InTransactionObservable(SQLConnection sqlConnection) |
| Modifier and Type | Method and Description |
|---|---|
ObservableSource<T> |
apply(Observable<T> upstream) |
public InTransactionObservable(SQLConnection sqlConnection)
sqlConnection - the connection used for transaction managementpublic ObservableSource<T> apply(Observable<T> upstream)
apply in interface ObservableTransformer<T,T>Copyright © 2020. All rights reserved.