public class CoderThread
extends java.lang.Thread
Modifier and Type | Field and Description |
---|---|
private java.io.PipedInputStream |
inSink |
private java.io.PipedOutputStream |
outSink |
private java.lang.Throwable |
throwable |
private java.lang.Runnable |
workhorse |
Constructor and Description |
---|
CoderThread(Coder coder,
java.io.InputStream in) |
CoderThread(Coder coder,
java.io.OutputStream out) |
Modifier and Type | Method and Description |
---|---|
void |
checkForException() |
protected boolean |
close(java.io.Closeable closeable) |
protected boolean |
flush(java.io.Flushable flushable) |
java.io.PipedInputStream |
getInputStreamSink() |
java.io.PipedOutputStream |
getOutputStreamSink() |
java.lang.Throwable |
getThrowable() |
void |
run() |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
private final java.io.PipedInputStream inSink
private final java.io.PipedOutputStream outSink
private final java.lang.Runnable workhorse
private java.lang.Throwable throwable
public CoderThread(Coder coder, java.io.InputStream in) throws java.io.IOException
java.io.IOException
public CoderThread(Coder coder, java.io.OutputStream out) throws java.io.IOException
java.io.IOException
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public java.lang.Throwable getThrowable()
public void checkForException() throws java.io.IOException
java.io.IOException
public java.io.PipedInputStream getInputStreamSink()
public java.io.PipedOutputStream getOutputStreamSink()
protected boolean flush(java.io.Flushable flushable)
protected boolean close(java.io.Closeable closeable)