public abstract class Utils extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
Utils.ExceptionFunction<T,R> |
static class |
Utils.SingleConnectionSupplier |
Constructor and Description |
---|
Utils() |
Modifier and Type | Method and Description |
---|---|
static <T> Mono<T> |
cache(Mono<T> mono) |
static Mono<? extends Connection> |
singleConnectionMono(Callable<? extends Connection> supplier) |
static Mono<? extends Connection> |
singleConnectionMono(ConnectionFactory connectionFactory) |
static Mono<? extends Connection> |
singleConnectionMono(ConnectionFactory cf,
Utils.ExceptionFunction<ConnectionFactory,? extends Connection> function) |
static Utils.ExceptionFunction<ConnectionFactory,? extends Connection> |
singleConnectionSupplier(Callable<? extends Connection> supplier) |
static Utils.ExceptionFunction<ConnectionFactory,? extends Connection> |
singleConnectionSupplier(ConnectionFactory cf) |
static Utils.ExceptionFunction<ConnectionFactory,? extends Connection> |
singleConnectionSupplier(ConnectionFactory cf,
Utils.ExceptionFunction<ConnectionFactory,? extends Connection> supplier) |
public static Mono<? extends Connection> singleConnectionMono(ConnectionFactory connectionFactory)
public static Mono<? extends Connection> singleConnectionMono(ConnectionFactory cf, Utils.ExceptionFunction<ConnectionFactory,? extends Connection> function)
public static Mono<? extends Connection> singleConnectionMono(Callable<? extends Connection> supplier)
public static Utils.ExceptionFunction<ConnectionFactory,? extends Connection> singleConnectionSupplier(ConnectionFactory cf, Utils.ExceptionFunction<ConnectionFactory,? extends Connection> supplier)
public static Utils.ExceptionFunction<ConnectionFactory,? extends Connection> singleConnectionSupplier(ConnectionFactory cf)
public static Utils.ExceptionFunction<ConnectionFactory,? extends Connection> singleConnectionSupplier(Callable<? extends Connection> supplier)