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,
Configuration conf) |
SiteStreamsImpl(twitter4j.internal.async.Dispatcher dispatcher,
java.io.InputStream stream,
Configuration conf) |
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 |
onUnfollow(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target) |
protected void |
onUserListCreation(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 |
onUserListMemberAddition(twitter4j.internal.org.json.JSONObject addedMember,
twitter4j.internal.org.json.JSONObject owner,
twitter4j.internal.org.json.JSONObject userList) |
protected void |
onUserListMemberDeletion(twitter4j.internal.org.json.JSONObject deletedMember,
twitter4j.internal.org.json.JSONObject owner,
twitter4j.internal.org.json.JSONObject userList) |
protected void |
onUserListSubscription(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject owner,
twitter4j.internal.org.json.JSONObject userList) |
protected void |
onUserListUnsubscription(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, Configuration conf) throws java.io.IOException
java.io.IOException
SiteStreamsImpl(twitter4j.internal.async.Dispatcher dispatcher, twitter4j.internal.http.HttpResponse response, Configuration conf) 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 onUnfollow(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject target) throws TwitterException
onUnfollow
in class AbstractStreamImplementation
TwitterException
protected void onUserListMemberAddition(twitter4j.internal.org.json.JSONObject addedMember, twitter4j.internal.org.json.JSONObject owner, twitter4j.internal.org.json.JSONObject userList) throws TwitterException, twitter4j.internal.org.json.JSONException
onUserListMemberAddition
in class AbstractStreamImplementation
TwitterException
twitter4j.internal.org.json.JSONException
protected void onUserListMemberDeletion(twitter4j.internal.org.json.JSONObject deletedMember, twitter4j.internal.org.json.JSONObject owner, twitter4j.internal.org.json.JSONObject userList) throws TwitterException, twitter4j.internal.org.json.JSONException
onUserListMemberDeletion
in class AbstractStreamImplementation
TwitterException
twitter4j.internal.org.json.JSONException
protected void onUserListSubscription(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
onUserListSubscription
in class AbstractStreamImplementation
TwitterException
twitter4j.internal.org.json.JSONException
protected void onUserListUnsubscription(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
onUserListUnsubscription
in class AbstractStreamImplementation
TwitterException
twitter4j.internal.org.json.JSONException
protected void onUserListCreation(twitter4j.internal.org.json.JSONObject source, twitter4j.internal.org.json.JSONObject userList) throws TwitterException, twitter4j.internal.org.json.JSONException
onUserListCreation
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