|
qflib 0.99 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
de.qfs.lib.util.StreamMultiplexer
Multiplexer that listens to input from an InputStream or a Reader and fires Events when new data arrives.
Field Summary |
Fields inherited from class java.lang.Thread |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
StreamMultiplexer(java.io.InputStream input)
Create a new StreamMultiplexer. |
|
StreamMultiplexer(java.io.InputStream input,
java.lang.Object source)
Create a new StreamMultiplexer. |
|
StreamMultiplexer(java.io.Reader reader)
Create a new StreamMultiplexer. |
|
StreamMultiplexer(java.io.Reader reader,
java.lang.Object source)
Create a new StreamMultiplexer. |
Method Summary | |
void |
addStreamListener(StreamListener listener)
Add a listener to the StreamMultiplexer. |
protected void |
fireInputClosed()
Notify all listeners that input source was closed. |
protected void |
fireNewInput(char[] data)
Notify all listeners that new data has arrived. |
java.lang.Object |
getSource()
Get the source for the events created by the StreamMultiplexer. |
void |
halt()
Halt the multiplexer. |
boolean |
isClosed()
Test whether the source of the Multiplexer has been closed or the multiplexer stopped. |
void |
removeStreamListener(StreamListener listener)
Remove a listener from the StreamMultiplexer. |
void |
run()
The actual work method of the thread. |
void |
setSource(java.lang.Object source)
Set the source for the events created by the StreamMultiplexer. |
Methods inherited from class java.lang.Thread |
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public StreamMultiplexer(java.io.InputStream input)
input
- The Stream to receive data from.public StreamMultiplexer(java.io.InputStream input, java.lang.Object source)
input
- The Stream to receive data from.source
- Optional object to use as source for the generated
StreamEvents. If null, the StreamMultiplexer itself
will be the source.public StreamMultiplexer(java.io.Reader reader)
reader
- The Reader to receive data from.public StreamMultiplexer(java.io.Reader reader, java.lang.Object source)
reader
- The Reader to receive data from.source
- Optional object to use as source for the generated
StreamEvents. If null, the StreamMultiplexer itself
will be the source.Method Detail |
public final java.lang.Object getSource()
public final void setSource(java.lang.Object source)
source
- The source to set.public final boolean isClosed()
public void run()
public void halt()
public void addStreamListener(StreamListener listener)
listener
- The listener to add.public void removeStreamListener(StreamListener listener)
listener
- The listener to remove.protected void fireNewInput(char[] data)
data
- The newly arrived data.protected void fireInputClosed()
|
qflib 0.99 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |