public abstract class AbstractXSRunnableXSWriter<T extends XSDataPacket<?,?>> extends AbstractXSRunnable implements XSWriter<T>
Constructor and Description |
---|
AbstractXSRunnableXSWriter(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
void |
connect(XSWritable<T> writable)
Connect to the XSWritable object
|
void |
disconnect(XSWritable<T> writable)
Disconnect from a XSWritable object
|
long |
getNumberOfPacketsSend()
Get the total number of packets send so far.
|
java.util.List<XSWritable<T>> |
getWritables()
Get all writables to which this writer is currently connected
|
void |
run() |
void |
write(T dataPacket)
Write onto all writable currently connected
|
interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable, workPackage
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getName, stop
public AbstractXSRunnableXSWriter(java.lang.String name)
public void connect(XSWritable<T> writable)
XSWriter
connect
in interface XSWriter<T extends XSDataPacket<?,?>>
writable
- to connect ontopublic void disconnect(XSWritable<T> writable)
XSWriter
disconnect
in interface XSWriter<T extends XSDataPacket<?,?>>
writable
- to disconnect frompublic void write(T dataPacket)
XSWriter
write
in interface XSWriter<T extends XSDataPacket<?,?>>
dataPacket
- to writepublic long getNumberOfPacketsSend()
XSWriter
getNumberOfPacketsSend
in interface XSWriter<T extends XSDataPacket<?,?>>
public java.util.List<XSWritable<T>> getWritables()
XSWriter
getWritables
in interface XSWriter<T extends XSDataPacket<?,?>>
public final void run()
run
in interface java.lang.Runnable
run
in class AbstractXSRunnable