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, yield
private 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.Runnable
run
in class java.lang.Thread
public void close()
private void setStatus(java.lang.String message)
abstract StatusStream getStream() throws TwitterException
TwitterException