Package com.smartgridready.communicator.async.process

Class WriteExec<V>

java.lang.Object

com.smartgridready.communicator.async.process.Processor

com.smartgridready.communicator.async.process.WriteExec<V>

All Implemented Interfaces:

Executable

public class WriteExec<V>
extends Processor
implements Executable

Constructor Summary

Constructors

Constructor	Description
WriteExec(java.lang.String functionalProfileName, java.lang.String dataPointName, WriteFunction<V> writeFunction)
WriteExec(java.lang.String functionalProfileName, java.lang.String dataPointName, WriteFunction<V> writeFunction, io.reactivex.rxjava3.core.Scheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	cleanup()
ExecStatus	getExecStatus()
java.lang.Throwable	getExecThrowable()
java.time.Instant	getRequestTime()
java.time.Instant	getResponseTime()
AsyncResult<V>	getResult()
void	process(ProcessingType processingType)
void	setFinishedNotificationReceiver(java.lang.Object notificationReceiver)
void	setWriteValue(V value)
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

WriteExec

public WriteExec(java.lang.String functionalProfileName,
                 java.lang.String dataPointName,
                 WriteFunction<V> writeFunction)

WriteExec

public WriteExec(java.lang.String functionalProfileName,
                 java.lang.String dataPointName,
                 WriteFunction<V> writeFunction,
                 io.reactivex.rxjava3.core.Scheduler scheduler)

Method Detail

process

public void process(ProcessingType processingType)

Specified by:

process in class Processor

setWriteValue

public void setWriteValue(V value)

getResult

public AsyncResult<V> getResult()

Specified by:

getResult in interface Executable

getExecStatus

public ExecStatus getExecStatus()

Specified by:

getExecStatus in interface Executable

getExecThrowable

public java.lang.Throwable getExecThrowable()

getRequestTime

public java.time.Instant getRequestTime()

getResponseTime

public java.time.Instant getResponseTime()

cleanup

public void cleanup()

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