class StatusStreamImpl extends StatusStreamBase
StatusStreamBase.StreamEvent
Modifier and Type | Field and Description |
---|---|
(package private) static RawStreamListener[] |
EMPTY |
(package private) java.lang.String |
line |
CONF, logger
Constructor and Description |
---|
StatusStreamImpl(Dispatcher dispatcher,
HttpResponse response,
Configuration conf) |
StatusStreamImpl(Dispatcher dispatcher,
java.io.InputStream stream,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
next(StatusListener listener)
Reads next status from this stream.
|
void |
next(StreamListener[] listeners,
RawStreamListener[] rawStreamListeners) |
protected void |
onClose() |
protected void |
onDelete(JSONObject json,
StreamListener[] listeners) |
void |
onException(java.lang.Exception e,
StreamListener[] listeners) |
protected void |
onLimit(JSONObject json,
StreamListener[] listeners) |
protected void |
onMessage(java.lang.String rawString,
RawStreamListener[] listeners) |
protected void |
onScrubGeo(JSONObject json,
StreamListener[] listeners) |
protected void |
onStallWarning(JSONObject json,
StreamListener[] listeners) |
protected void |
onStatus(JSONObject json,
StreamListener[] listeners) |
protected java.lang.String |
parseLine(java.lang.String line) |
asDirectMessage, asFriendList, asStatus, asUser, asUserList, close, handleNextElement, onBlock, onDirectMessage, onDisconnectionNotice, onException, onFavorite, onFavoritedRetweet, onFollow, onFriends, onMute, onQuotedTweet, onRetweetedRetweet, onSender, onUnblock, onUnfavorite, onUnfollow, onUnmute, onUserDeletion, onUserListCreation, onUserListDestroyed, onUserListMemberAddition, onUserListMemberDeletion, onUserListSubscription, onUserListUnsubscription, onUserListUpdated, onUserSuspension, onUserUpdate
java.lang.String line
static final RawStreamListener[] EMPTY
StatusStreamImpl(Dispatcher dispatcher, java.io.InputStream stream, Configuration conf) throws java.io.IOException
java.io.IOException
StatusStreamImpl(Dispatcher dispatcher, HttpResponse response, Configuration conf) throws java.io.IOException
java.io.IOException
protected void onClose()
onClose
in class StatusStreamBase
public void next(StatusListener listener) throws TwitterException
StatusStream
next
in interface StatusStream
next
in class StatusStreamBase
listener
- a StatusListener implementationTwitterException
- when the end of the stream has been reached.public void next(StreamListener[] listeners, RawStreamListener[] rawStreamListeners) throws TwitterException
next
in class StatusStreamBase
TwitterException
protected java.lang.String parseLine(java.lang.String line)
parseLine
in class StatusStreamBase
protected void onMessage(java.lang.String rawString, RawStreamListener[] listeners) throws TwitterException
onMessage
in class StatusStreamBase
TwitterException
protected void onStatus(JSONObject json, StreamListener[] listeners) throws TwitterException
onStatus
in class StatusStreamBase
TwitterException
protected void onDelete(JSONObject json, StreamListener[] listeners) throws TwitterException, JSONException
onDelete
in class StatusStreamBase
TwitterException
JSONException
protected void onLimit(JSONObject json, StreamListener[] listeners) throws TwitterException, JSONException
onLimit
in class StatusStreamBase
TwitterException
JSONException
protected void onStallWarning(JSONObject json, StreamListener[] listeners) throws TwitterException, JSONException
onStallWarning
in class StatusStreamBase
TwitterException
JSONException
protected void onScrubGeo(JSONObject json, StreamListener[] listeners) throws TwitterException, JSONException
onScrubGeo
in class StatusStreamBase
TwitterException
JSONException
public void onException(java.lang.Exception e, StreamListener[] listeners)
onException
in class StatusStreamBase