abstract class TwitterStreamImpl.TwitterStreamConsumer
extends java.lang.Thread
| Modifier and Type | Field and Description |
|---|---|
private boolean |
closed |
private TwitterStreamImpl.Mode |
mode |
private java.lang.String |
NAME |
private RawStreamListener[] |
rawStreamListeners |
private StatusStreamBase |
stream |
private StreamListener[] |
streamListeners |
| Constructor and Description |
|---|
TwitterStreamConsumer(TwitterStreamImpl.Mode mode) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
(package private) abstract StatusStream |
getStream() |
void |
run() |
private void |
setStatus(java.lang.String message) |
(package private) void |
updateListeners() |
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, yieldprivate StatusStreamBase stream
private final java.lang.String NAME
private volatile boolean closed
private StreamListener[] streamListeners
private RawStreamListener[] rawStreamListeners
private final TwitterStreamImpl.Mode mode
TwitterStreamConsumer(TwitterStreamImpl.Mode mode)
void updateListeners()
public void run()
run in interface java.lang.Runnablerun in class java.lang.Threadpublic void close()
private void setStatus(java.lang.String message)
abstract StatusStream getStream() throws TwitterException
TwitterException