public interface Tx<T>
| Modifier and Type | Method and Description |
|---|---|
static <T> io.reactivex.functions.Function<Tx<T>,io.reactivex.Flowable<T>> |
flattenToValuesOnly() |
boolean |
isComplete() |
boolean |
isError() |
boolean |
isValue() |
TransactedSelectBuilder |
select(String sql) |
Throwable |
throwable() |
static <T> io.reactivex.Flowable<Tx<T>> |
toTx(io.reactivex.Notification<T> n,
Connection con,
Database db) |
static <T> io.reactivex.functions.Function<Tx<T>,T> |
toValue() |
TransactedUpdateBuilder |
update(String sql) |
T |
value() |
static <T> io.reactivex.functions.Predicate<Tx<T>> |
valuesOnly() |
boolean isValue()
boolean isComplete()
boolean isError()
T value()
Throwable throwable()
TransactedSelectBuilder select(String sql)
TransactedUpdateBuilder update(String sql)
static <T> io.reactivex.functions.Predicate<Tx<T>> valuesOnly()
static <T> io.reactivex.functions.Function<Tx<T>,io.reactivex.Flowable<T>> flattenToValuesOnly()
static <T> io.reactivex.functions.Function<Tx<T>,T> toValue()
static <T> io.reactivex.Flowable<Tx<T>> toTx(io.reactivex.Notification<T> n, Connection con, Database db)
Copyright © 2016–2017. All rights reserved.