PVConfiguration<R,W> |
PVConfiguration.from(DataSource dataSource) |
PVConfiguration<R,W> |
PVConfiguration.notifyOn(Executor onThread) |
static <R,W> PVConfiguration<R,W> |
PVManager.readAndWrite(DesiredRateReadWriteExpression<R,W> readWriteExpression)
Both reads and writes the given expression, and returns an object to configure the parameters
for the both read and write.
|
static <R,W> PVConfiguration<R,W> |
PVManager.readAndWrite(SourceRateReadWriteExpression<R,W> readWriteExpression)
Both reads and writes the given expression, and returns an object to configure the parameters
for the both read and write.
|
PVConfiguration<R,W> |
PVConfiguration.readListener(PVReaderListener<? super R> listener)
Adds a listener for the read events.
|
PVConfiguration<R,W> |
PVConfiguration.routeExceptionsTo(ExceptionHandler exceptionHandler)
Forwards exception to the given exception handler.
|
PVConfiguration<R,W> |
PVConfiguration.timeout(TimeDuration timeout)
Sets a timeout for both reader and writer.
|
PVConfiguration<R,W> |
PVConfiguration.timeout(TimeDuration timeout,
String timeoutMessage)
Sets a timeout with the given message for both read and writer.
|
PVConfiguration<R,W> |
PVConfiguration.timeout(TimeDuration timeout,
String readMessage,
String writeMessage)
Specifies a timeout, with a different message for the read and the write.
|
PVConfiguration<R,W> |
PVConfiguration.writeListener(PVWriterListener<? extends W> listener)
Adds a listener for the write events.
|
