public class StreamPumper extends AbstractStreamHandler
Modifier and Type | Field and Description |
---|---|
private StreamConsumer |
consumer |
private java.lang.Exception |
exception |
private java.io.BufferedReader |
in |
private java.io.PrintWriter |
out |
private static int |
SIZE |
Modifier | Constructor and Description |
---|---|
|
StreamPumper(java.io.InputStream in,
StreamConsumer consumer) |
|
StreamPumper(java.io.InputStream in,
StreamConsumer consumer,
java.nio.charset.Charset charset) |
private |
StreamPumper(java.io.Reader in,
java.io.PrintWriter writer,
StreamConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close it.
|
private void |
consumeLine(java.lang.String line) |
void |
flush()
flush.
|
java.lang.Exception |
getException() |
void |
run()
run it.
|
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.io.BufferedReader in
private final StreamConsumer consumer
private final java.io.PrintWriter out
private volatile java.lang.Exception exception
private static final int SIZE
public StreamPumper(java.io.InputStream in, StreamConsumer consumer)
in
- InputStream
consumer
- StreamConsumer
public StreamPumper(java.io.InputStream in, StreamConsumer consumer, @Nullable java.nio.charset.Charset charset)
in
- InputStream
consumer
- StreamConsumer
charset
- Charset
private StreamPumper(java.io.Reader in, java.io.PrintWriter writer, StreamConsumer consumer)
in
- Writer
writer
- PrintWriter
consumer
- StreamConsumer
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void flush()
public void close()
public java.lang.Exception getException()
Exception
private void consumeLine(java.lang.String line)