public abstract class AbstractJsonXSAuthor<D extends XSDataPacket<?,?>,V> extends AbstractXSAuthor<D,V>
Modifier and Type | Field and Description |
---|---|
protected java.io.Reader |
externalStreamReader |
protected com.google.gson.JsonStreamParser |
jsonStream |
Constructor and Description |
---|
AbstractJsonXSAuthor(java.lang.String name,
XSVisualization<V> visualization) |
Modifier and Type | Method and Description |
---|---|
protected abstract java.io.Reader |
establishReaderConnectionToSource() |
protected void |
reConnect() |
void |
startXSRunnable() |
void |
stopXSRunnable() |
getVisualization, interrupt, pause, pauseXSRunnable, start
connect, disconnect, getNumberOfPacketsSend, getWritables, run, write
isPaused, isRunning, isStarted, isStopped, 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, isPaused, isRunning, isStarted, isStopped, stop
connect, disconnect, getNumberOfPacketsSend, getWritables, write
getTopic
protected com.google.gson.JsonStreamParser jsonStream
protected java.io.Reader externalStreamReader
public AbstractJsonXSAuthor(java.lang.String name, XSVisualization<V> visualization)
public void startXSRunnable()
startXSRunnable
in interface XSRunnable
startXSRunnable
in class AbstractXSAuthor<D extends XSDataPacket<?,?>,V>
public void stopXSRunnable()
stopXSRunnable
in interface XSRunnable
stopXSRunnable
in class AbstractXSAuthor<D extends XSDataPacket<?,?>,V>
protected abstract java.io.Reader establishReaderConnectionToSource()
protected void reConnect()