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 Object

Method Summary

Modifier and Type	Method and Description
NonBlockingPool<T>	build()
NonBlockingPool.Builder<T>	disposer(io.reactivex.functions.Consumer<T> disposer)
NonBlockingPool.Builder<T>	factory(Callable<T> factory)
NonBlockingPool.Builder<T>	healthy(io.reactivex.functions.Predicate<T> healthy)
NonBlockingPool.Builder<T>	idleTimeBeforeHealthCheck(long value, TimeUnit unit)
NonBlockingPool.Builder<T>	idleTimeBeforeHealthCheckMs(long value)
NonBlockingPool.Builder<T>	maxIdleTime(long value, TimeUnit unit)
NonBlockingPool.Builder<T>	maxIdleTimeMs(long value)
NonBlockingPool.Builder<T>	maxSize(int maxSize)
NonBlockingPool.Builder<T>	memberFactory(MemberFactory<T,NonBlockingPool<T>> memberFactory)
NonBlockingPool.Builder<T>	returnToPoolDelayAfterHealthCheckFailure(long value, TimeUnit unit)
NonBlockingPool.Builder<T>	returnToPoolDelayAfterHealthCheckFailureMs(long retryDelayMs)
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(Callable<T> factory)

healthy

public NonBlockingPool.Builder<T> healthy(io.reactivex.functions.Predicate<T> healthy)

idleTimeBeforeHealthCheckMs

public NonBlockingPool.Builder<T> idleTimeBeforeHealthCheckMs(long value)

idleTimeBeforeHealthCheck

public NonBlockingPool.Builder<T> idleTimeBeforeHealthCheck(long value,
                                                            TimeUnit unit)

maxIdleTimeMs

public NonBlockingPool.Builder<T> maxIdleTimeMs(long value)

maxIdleTime

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

disposer

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

maxSize

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

returnToPoolDelayAfterHealthCheckFailureMs

public NonBlockingPool.Builder<T> returnToPoolDelayAfterHealthCheckFailureMs(long retryDelayMs)

returnToPoolDelayAfterHealthCheckFailure

public NonBlockingPool.Builder<T> returnToPoolDelayAfterHealthCheckFailure(long value,
                                                                           TimeUnit unit)

memberFactory

public NonBlockingPool.Builder<T> memberFactory(MemberFactory<T,NonBlockingPool<T>> memberFactory)

scheduler

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

build

public NonBlockingPool<T> build()