org.davidmoten.rxjava3.jdbc

Interface Tx<T>

All Superinterfaces:

TxWithoutValue

public interface Tx<T>
extends TxWithoutValue

Method Summary

Modifier and Type	Method and Description
static <T> io.reactivex.rxjava3.functions.Function<Tx<T>,io.reactivex.rxjava3.core.Flowable<T>>	flattenToValuesOnly()
boolean	isValue()
static <T> io.reactivex.rxjava3.core.Flowable<Tx<T>>	toTx(io.reactivex.rxjava3.core.Notification<T> n, Connection con, Database db)
static <T> io.reactivex.rxjava3.functions.Function<Tx<T>,T>	toValue()
T	value()
static <T> io.reactivex.rxjava3.functions.Predicate<Tx<T>>	valuesOnly()

Methods inherited from interface org.davidmoten.rxjava3.jdbc.TxWithoutValue

call, isComplete, isError, select, throwable, update

Method Detail

isValue

boolean isValue()

value

T value()

valuesOnly

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

flattenToValuesOnly

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

toValue

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

toTx

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