org.davidmoten.rx.pool

Class NonBlockingPool.Builder<T>

java.lang.Object

org.davidmoten.rx.pool.NonBlockingPool.Builder<T>

Enclosing class:

NonBlockingPool<T>

public static class NonBlockingPool.Builder<T>
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
NonBlockingPool<T>	build()
NonBlockingPool.Builder<T>	checkinDecorator(java.util.function.BiFunction<? super T,? super Checkin,? extends T> f)
NonBlockingPool.Builder<T>	createRetryInterval(long duration, java.util.concurrent.TimeUnit unit)
NonBlockingPool.Builder<T>	disposer(io.reactivex.functions.Consumer<? super T> disposer)
NonBlockingPool.Builder<T>	factory(java.util.concurrent.Callable<? extends T> factory)
NonBlockingPool.Builder<T>	healthCheck(io.reactivex.functions.Predicate<? super T> healthCheck)
NonBlockingPool.Builder<T>	idleTimeBeforeHealthCheck(long duration, java.util.concurrent.TimeUnit unit)
NonBlockingPool.Builder<T>	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>	maxSize(int maxSize)
NonBlockingPool.Builder<T>	onClose(io.reactivex.functions.Action closeAction)
NonBlockingPool.Builder<T>	scheduler(io.reactivex.Scheduler scheduler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

factory

public NonBlockingPool.Builder<T> factory(java.util.concurrent.Callable<? extends T> factory)

healthCheck

public NonBlockingPool.Builder<T> healthCheck(io.reactivex.functions.Predicate<? super T> healthCheck)

idleTimeBeforeHealthCheck

public NonBlockingPool.Builder<T> idleTimeBeforeHealthCheck(long duration,
                                                            java.util.concurrent.TimeUnit unit)

maxIdleTime

public NonBlockingPool.Builder<T> maxIdleTime(long value,
                                              java.util.concurrent.TimeUnit unit)

Sets the maximum time a connection can remaing idle before being scheduled for release (closure). If set to 0 (regardless of unit) then idle connections are not released. If not set the default value is 30 minutes.

Parameters:

value - duration

unit - unit of the duration

Returns:

this

createRetryInterval

public NonBlockingPool.Builder<T> createRetryInterval(long duration,
                                                      java.util.concurrent.TimeUnit unit)

disposer

public NonBlockingPool.Builder<T> disposer(io.reactivex.functions.Consumer<? super T> disposer)

maxSize

public NonBlockingPool.Builder<T> maxSize(int maxSize)

scheduler

public NonBlockingPool.Builder<T> scheduler(io.reactivex.Scheduler scheduler)

checkinDecorator

public NonBlockingPool.Builder<T> checkinDecorator(java.util.function.BiFunction<? super T,? super Checkin,? extends T> f)

onClose

public NonBlockingPool.Builder<T> onClose(io.reactivex.functions.Action closeAction)

build

public NonBlockingPool<T> build()