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