org.davidmoten.rx.jdbc

Interface Tx<T>

public interface Tx<T>

Method Summary

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()

Method Detail

isValue

boolean isValue()

isComplete

boolean isComplete()

isError

boolean isError()

value

T value()

throwable

Throwable throwable()

select

TransactedSelectBuilder select(String sql)

update

TransactedUpdateBuilder update(String sql)

valuesOnly

static <T> io.reactivex.functions.Predicate<Tx<T>> valuesOnly()

flattenToValuesOnly

static <T> io.reactivex.functions.Function<Tx<T>,io.reactivex.Flowable<T>> flattenToValuesOnly()

toValue

static <T> io.reactivex.functions.Function<Tx<T>,T> toValue()

toTx

static <T> io.reactivex.Flowable<Tx<T>> toTx(io.reactivex.Notification<T> n,
                                             Connection con,
                                             Database db)