Package com.smartgridready.communicator.async.process

Class ReadExec<R>

java.lang.Object

com.smartgridready.communicator.async.process.Processor

com.smartgridready.communicator.async.process.ReadExec<R>

All Implemented Interfaces:

Executable

public class ReadExec<R>
extends Processor
implements Executable

Constructor Summary

Constructors

Constructor	Description
ReadExec(java.lang.String functionalProfileName, java.lang.String dataPointName, ReadFunction<R> readFunction)
ReadExec(java.lang.String functionalProfileName, java.lang.String dataPointName, ReadFunction<R> readFunction, io.reactivex.rxjava3.core.Scheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	cleanup()
ExecStatus	getExecStatus()
java.lang.Throwable	getExecThrowable()
R	getReadValue()
java.time.Instant	getRequestTime()
java.time.Instant	getResponseTime()
AsyncResult<R>	getResult()
void	handleError(java.lang.Throwable t)
void	handleSuccess(AsyncResult<R> result)
void	process(ProcessingType processingType)
void	setFinishedNotificationReceiver(java.lang.Object notificationReceiver)
java.lang.String	toString()

Methods inherited from class com.smartgridready.communicator.async.process.Processor

await, process

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadExec

public ReadExec(java.lang.String functionalProfileName,
                java.lang.String dataPointName,
                ReadFunction<R> readFunction)

ReadExec

public ReadExec(java.lang.String functionalProfileName,
                java.lang.String dataPointName,
                ReadFunction<R> readFunction,
                io.reactivex.rxjava3.core.Scheduler scheduler)

Method Detail

process

public void process(ProcessingType processingType)

Specified by:

process in class Processor

handleSuccess

public void handleSuccess(AsyncResult<R> result)

handleError

public void handleError(java.lang.Throwable t)

getResult

public AsyncResult<R> getResult()

Specified by:

getResult in interface Executable

getReadValue

public R getReadValue()

getExecStatus

public ExecStatus getExecStatus()

Specified by:

getExecStatus in interface Executable

getExecThrowable

public java.lang.Throwable getExecThrowable()

cleanup

public void cleanup()

getRequestTime

public java.time.Instant getRequestTime()

getResponseTime

public java.time.Instant getResponseTime()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

setFinishedNotificationReceiver

public void setFinishedNotificationReceiver(java.lang.Object notificationReceiver)

Specified by:

setFinishedNotificationReceiver in interface Executable