| Package | Description |
|---|---|
| org.davidmoten.rx.pool |
| Modifier and Type | Method and Description |
|---|---|
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.checkinDecorator(java.util.function.BiFunction<? super T,? super Checkin,? extends T> f) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.createRetryInterval(long duration,
java.util.concurrent.TimeUnit unit) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.disposer(io.reactivex.functions.Consumer<? super T> disposer) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.factory(java.util.concurrent.Callable<? extends T> factory) |
static <T> NonBlockingPool.Builder<T> |
NonBlockingPool.factory(java.util.concurrent.Callable<T> factory) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.healthCheck(io.reactivex.functions.Predicate<? super T> healthCheck) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.idleTimeBeforeHealthCheck(long duration,
java.util.concurrent.TimeUnit unit) |
NonBlockingPool.Builder<T> |
NonBlockingPool.Builder.maxIdleTime(long value,
java.util.concurrent.TimeUnit unit)
Sets the maximum time a connection can remaing idle before being scheduled
for release (closure).
|
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) |
Copyright © 2016–2020. All rights reserved.