class SiteStreamsImpl extends AbstractStreamImplementation implements StreamImplementation, StreamListener
AbstractStreamImplementation.StreamEvent
Modifier and Type | Field and Description |
---|---|
private static java.lang.ThreadLocal<java.lang.Integer> |
forUser |
(package private) SiteStreamsListener |
listener |
dispatcher, logger
Constructor and Description |
---|
SiteStreamsImpl(twitter4j.internal.async.Dispatcher dispatcher,
twitter4j.internal.http.HttpResponse response) |
SiteStreamsImpl(twitter4j.internal.async.Dispatcher dispatcher,
java.io.InputStream stream) |
Modifier and Type | Method and Description |
---|---|
void |
next(StreamListener[] listeners) |
protected void |
onBlock(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target) |
protected void |
onDelete(twitter4j.internal.org.json.JSONObject json) |
protected void |
onDirectMessage(twitter4j.internal.org.json.JSONObject json) |
void |
onException(java.lang.Exception ex) |
protected void |
onFavorite(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target,
twitter4j.internal.org.json.JSONObject targetObject) |
protected void |
onFollow(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target) |
protected void |
onFriends(twitter4j.internal.org.json.JSONObject json) |
protected void |
onStatus(twitter4j.internal.org.json.JSONObject json) |
protected void |
onUnblock(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target) |
protected void |
onUnfavorite(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target,
twitter4j.internal.org.json.JSONObject targetObject) |
protected void |
onUserListCreated(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject userList) |
protected void |
onUserListDestroyed(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject userList) |
protected void |
onUserListSubscribed(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject owner,
twitter4j.internal.org.json.JSONObject userList) |
protected void |
onUserListUpdated(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject userList) |
protected void |
onUserUpdate(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target) |
protected java.lang.String |
parseLine(java.lang.String line) |
asDirectMessage, asFriendList, asStatus, asUser, asUserList, close, handleNextElement, onLimit, onRetweet, onScrubGeo, onSender
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
SiteStreamsListener listener
private static java.lang.ThreadLocal<java.lang.Integer> forUser
SiteStreamsImpl(twitter4j.internal.async.Dispatcher dispatcher, java.io.InputStream stream) throws java.io.IOException
java.io.IOException
SiteStreamsImpl(twitter4j.internal.async.Dispatcher dispatcher, twitter4j.internal.http.HttpResponse response) throws java.io.IOException
java.io.IOException
public void next(StreamListener[] listeners) throws TwitterException
next
in interface StreamImplementation
next
in class AbstractStreamImplementation
TwitterException
protected java.lang.String parseLine(java.lang.String line)
parseLine
in class AbstractStreamImplementation
protected void onStatus(twitter4j.internal.org.json.JSONObject json) throws TwitterException
onStatus
in class AbstractStreamImplementation
TwitterException
protected void onDelete(twitter4j.internal.org.json.JSONObject json) throws twitter4j.internal.org.json.JSONException
onDelete
in class AbstractStreamImplementation
twitter4j.internal.org.json.JSONException
protected void onDirectMessage(twitter4j.internal.org.json.JSONObject json) throws TwitterException
onDirectMessage
in class AbstractStreamImplementation
TwitterException
protected void onFriends(twitter4j.internal.org.json.JSONObject json) throws TwitterException, twitter4j.internal.org.json.JSONException
onFriends
in class AbstractStreamImplementation
TwitterException
twitter4j.internal.org.json.JSONException
protected void onFavorite(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject target, twitter4j.internal.org.json.JSONObject targetObject) throws TwitterException
onFavorite
in class AbstractStreamImplementation
TwitterException
protected void onUnfavorite(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject target, twitter4j.internal.org.json.JSONObject targetObject) throws TwitterException
onUnfavorite
in class AbstractStreamImplementation
TwitterException
protected void onFollow(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject target) throws TwitterException
onFollow
in class AbstractStreamImplementation
TwitterException
protected void onUserListSubscribed(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject owner, twitter4j.internal.org.json.JSONObject userList) throws TwitterException, twitter4j.internal.org.json.JSONException
onUserListSubscribed
in class AbstractStreamImplementation
TwitterException
twitter4j.internal.org.json.JSONException
protected void onUserListCreated(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject userList) throws TwitterException, twitter4j.internal.org.json.JSONException
onUserListCreated
in class AbstractStreamImplementation
TwitterException
twitter4j.internal.org.json.JSONException
protected void onUserListUpdated(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject userList) throws TwitterException, twitter4j.internal.org.json.JSONException
onUserListUpdated
in class AbstractStreamImplementation
TwitterException
twitter4j.internal.org.json.JSONException
protected void onUserListDestroyed(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject userList) throws TwitterException
onUserListDestroyed
in class AbstractStreamImplementation
TwitterException
protected void onUserUpdate(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject target) throws TwitterException
onUserUpdate
in class AbstractStreamImplementation
TwitterException
protected void onBlock(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject target) throws TwitterException
onBlock
in class AbstractStreamImplementation
TwitterException
protected void onUnblock(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject target) throws TwitterException
onUnblock
in class AbstractStreamImplementation
TwitterException
public void onException(java.lang.Exception ex)
onException
in interface StreamImplementation
onException
in interface StreamListener
onException
in class AbstractStreamImplementation