org.davidmoten.rx.jdbc.pool.internal

Class SerializedConnectionListener

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

org.davidmoten.rx.jdbc.pool.internal.SerializedConnectionListener

All Implemented Interfaces:

io.reactivex.functions.Consumer<java.util.Optional<java.lang.Throwable>>, java.io.Serializable

public final class SerializedConnectionListener
extends java.util.concurrent.atomic.AtomicInteger
implements io.reactivex.functions.Consumer<java.util.Optional<java.lang.Throwable>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SerializedConnectionListener(io.reactivex.functions.Consumer<? super java.util.Optional<java.lang.Throwable>> c)

Method Summary

Modifier and Type	Method and Description
void	accept(java.util.Optional<java.lang.Throwable> error)

Methods inherited from class java.util.concurrent.atomic.AtomicInteger

accumulateAndGet, addAndGet, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, incrementAndGet, intValue, lazySet, longValue, set, toString, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializedConnectionListener

public SerializedConnectionListener(io.reactivex.functions.Consumer<? super java.util.Optional<java.lang.Throwable>> c)

Method Detail

accept

public void accept(java.util.Optional<java.lang.Throwable> error)
            throws java.lang.Exception

Specified by:

accept in interface io.reactivex.functions.Consumer<java.util.Optional<java.lang.Throwable>>

Throws:

java.lang.Exception