class StreamFeeder extends AbstractStreamHandler
Modifier and Type | Field and Description |
---|---|
private java.lang.Throwable |
exception |
private java.util.concurrent.atomic.AtomicReference<java.io.InputStream> |
input |
private java.util.concurrent.atomic.AtomicReference<java.io.OutputStream> |
output |
Constructor and Description |
---|
StreamFeeder(java.io.InputStream input,
java.io.OutputStream output)
Create a new StreamFeeder
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
private void |
feed() |
java.lang.Throwable |
getException() |
void |
run() |
disable, isDisabled, isDone, setDone, waitUntilDone
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.util.concurrent.atomic.AtomicReference<java.io.InputStream> input
private final java.util.concurrent.atomic.AtomicReference<java.io.OutputStream> output
private volatile java.lang.Throwable exception
StreamFeeder(java.io.InputStream input, java.io.OutputStream output)
input
- Stream to read fromoutput
- Stream to write topublic void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void close()
public java.lang.Throwable getException()
private void feed() throws java.io.IOException
java.io.IOException