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 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,
StreamConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
As of 3.2.0, removed without replacement.
|
private void |
consumeLine(java.lang.String line) |
void |
flush()
Deprecated.
As of 3.2.0, removed without replacement.
|
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 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, StreamConsumer consumer)
in
- Reader
consumer
- StreamConsumer
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
@Deprecated public void flush()
@Deprecated public void close()
public java.lang.Exception getException()
Exception
private void consumeLine(java.lang.String line) throws java.io.IOException
java.io.IOException