NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.checkinDecorator(BiFunction<? super T,? super Checkin,? extends T> f) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.createRetryInterval(long duration,
TimeUnit unit) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.disposer(io.reactivex.functions.Consumer<? super T> disposer) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.factory(Callable<? extends T> factory) |
static <T> NonBlockingPool.Builder<T> |
NonBlockingPool.factory(Callable<T> factory) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.healthCheck(io.reactivex.functions.Predicate<? super T> healthCheck) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.idleTimeBeforeHealthCheck(long duration,
TimeUnit unit) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.maxIdleTime(long value,
TimeUnit unit) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.maxSize(int maxSize) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.onClose(io.reactivex.functions.Action closeAction) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.scheduler(io.reactivex.Scheduler scheduler) |