NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.disposer(io.reactivex.functions.Consumer<T> disposer) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.factory(Callable<T> factory) |
static <T> NonBlockingPool.Builder<T> |
NonBlockingPool.factory(Callable<T> factory) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.healthy(io.reactivex.functions.Predicate<T> healthy) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.idleTimeBeforeHealthCheck(long value,
TimeUnit unit) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.idleTimeBeforeHealthCheckMs(long value) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.maxIdleTime(long value,
TimeUnit unit) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.maxIdleTimeMs(long value) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.maxSize(int maxSize) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.memberFactory(MemberFactory<T,NonBlockingPool<T>> memberFactory) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.returnToPoolDelayAfterHealthCheckFailure(long value,
TimeUnit unit) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.returnToPoolDelayAfterHealthCheckFailureMs(long retryDelayMs) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.scheduler(io.reactivex.Scheduler scheduler) |