abstract class TwitterStreamImpl.TwitterStreamConsumer
extends java.lang.Thread
| Modifier and Type | Field and Description | 
|---|---|
private boolean | 
closed  | 
private java.lang.String | 
NAME  | 
private RawStreamListener[] | 
rawStreamListeners  | 
private StatusStreamBase | 
stream  | 
private StreamListener[] | 
streamListeners  | 
| Constructor and Description | 
|---|
TwitterStreamImpl.TwitterStreamConsumer(java.util.List<StreamListener> streamListeners,
                                       java.util.List<RawStreamListener> rawStreamListeners)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
close()  | 
(package private) abstract StatusStream | 
getStream()  | 
void | 
run()  | 
private void | 
setStatus(java.lang.String message)  | 
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 final StreamListener[] streamListeners
private final RawStreamListener[] rawStreamListeners
TwitterStreamImpl.TwitterStreamConsumer(java.util.List<StreamListener> streamListeners, java.util.List<RawStreamListener> rawStreamListeners)
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