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, writedeliver, getCommunicationType, getDeliveryLock, getHandlingTimes, getLatestWritingThread, getMemoryUsage, getNextHandlingTimeIndex, getNextMemoryUsageIndex, getNextPacket, getNumberOfPacketsReceived, getPacketHandlingTimes, getPerformanceTrackerStepSize, getUsedMemory, isTrackingPerformance, isTrackPerformance, measureUsedMemory, setHandlingTimes, setLatestWritingThread, setMemoryUsage, setNextHandlingTimeIndex, setNextMemoryUsageIndex, setPerformanceTrackerStepSize, setTrackPerformance, storeNewPacket, triggerPacketHandle, workPackageinterrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnableactiveCount, 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, yieldequals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetName, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stop, stopXSRunnabledeliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandledisconnect, getNumberOfPacketsSend, getWritables, writegetTopicgetVisualizationpublic AbstractXSStream(java.lang.String name,
XSSignature signature,
CommunicationType communicationType)
public void connect(XSWritable<T> writable)
XSWriterconnect 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<?,?>>