public abstract class AbstractXSStream<T extends XSDataPacket<?,?>> extends AbstractXSHub<T,T> implements XSStream<T>
Constructor and Description |
---|
AbstractXSStream(java.lang.String name,
XSSignature signature,
CommunicationType communicationType) |
Modifier and Type | Method and Description |
---|---|
void |
connect(XSWritable<T> writable)
Connect to the XSWritable object
|
XSSignature |
getSignature() |
protected T |
transform(T packet) |
disconnect, getNumberOfPacketsSend, getWritables, getWriterDelegate, handleNextPacket, run, write
deliver, getCommunicationType, getDeliveryLock, getHandlingTimes, getLatestWritingThread, getMemoryUsage, getNextHandlingTimeIndex, getNextMemoryUsageIndex, getNextPacket, getNumberOfPacketsReceived, getPacketHandlingTimes, getPerformanceTrackerStepSize, getUsedMemory, isTrackingPerformance, isTrackPerformance, measureUsedMemory, setHandlingTimes, setLatestWritingThread, setMemoryUsage, setNextHandlingTimeIndex, setNextMemoryUsageIndex, setPerformanceTrackerStepSize, setTrackPerformance, storeNewPacket, triggerPacketHandle, workPackage
interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable
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, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stop, stopXSRunnable
deliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandle
disconnect, getNumberOfPacketsSend, getWritables, write
getTopic
getVisualization
public AbstractXSStream(java.lang.String name, XSSignature signature, CommunicationType communicationType)
public void connect(XSWritable<T> writable)
XSWriter
connect
in interface XSWriter<T extends XSDataPacket<?,?>>
connect
in class AbstractXSHub<T extends XSDataPacket<?,?>,T extends XSDataPacket<?,?>>
writable
- to connect ontopublic XSSignature getSignature()
getSignature
in interface XSStream<T extends XSDataPacket<?,?>>
protected T transform(T packet)
transform
in class AbstractXSHub<T extends XSDataPacket<?,?>,T extends XSDataPacket<?,?>>