abstract class AbstractStreamImplementation
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
AbstractStreamImplementation.StreamEvent |
| Modifier and Type | Field and Description |
|---|---|
private java.io.BufferedReader |
br |
protected Configuration |
CONF |
protected twitter4j.internal.async.Dispatcher |
dispatcher |
protected twitter4j.internal.json.z_T4JInternalFactory |
factory |
private java.io.InputStream |
is |
protected static twitter4j.internal.logging.Logger |
logger |
private twitter4j.internal.http.HttpResponse |
response |
private boolean |
streamAlive |
| Constructor and Description |
|---|
AbstractStreamImplementation(twitter4j.internal.async.Dispatcher dispatcher,
twitter4j.internal.http.HttpResponse response,
Configuration conf) |
AbstractStreamImplementation(twitter4j.internal.async.Dispatcher dispatcher,
java.io.InputStream stream,
Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
protected DirectMessage |
asDirectMessage(twitter4j.internal.org.json.JSONObject json) |
protected long[] |
asFriendList(twitter4j.internal.org.json.JSONObject json) |
protected Status |
asStatus(twitter4j.internal.org.json.JSONObject json) |
protected User |
asUser(twitter4j.internal.org.json.JSONObject json) |
protected UserList |
asUserList(twitter4j.internal.org.json.JSONObject json) |
void |
close() |
protected void |
handleNextElement() |
(package private) abstract 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) |
protected void |
onException(java.lang.Exception e) |
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 |
onLimit(twitter4j.internal.org.json.JSONObject json) |
protected void |
onRetweet(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target,
twitter4j.internal.org.json.JSONObject targetObject) |
protected void |
onScrubGeo(twitter4j.internal.org.json.JSONObject json) |
protected void |
onSender(twitter4j.internal.org.json.JSONObject json) |
protected void |
onStallWarning(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) |
protected static final twitter4j.internal.logging.Logger logger
private boolean streamAlive
private java.io.BufferedReader br
private java.io.InputStream is
private twitter4j.internal.http.HttpResponse response
protected final twitter4j.internal.async.Dispatcher dispatcher
protected final Configuration CONF
protected twitter4j.internal.json.z_T4JInternalFactory factory
AbstractStreamImplementation(twitter4j.internal.async.Dispatcher dispatcher,
java.io.InputStream stream,
Configuration conf)
throws java.io.IOException
java.io.IOExceptionAbstractStreamImplementation(twitter4j.internal.async.Dispatcher dispatcher,
twitter4j.internal.http.HttpResponse response,
Configuration conf)
throws java.io.IOException
java.io.IOExceptionprotected java.lang.String parseLine(java.lang.String line)
abstract void next(StreamListener[] listeners) throws TwitterException
TwitterExceptionprotected void handleNextElement()
throws TwitterException
TwitterExceptionprotected void onSender(twitter4j.internal.org.json.JSONObject json)
throws TwitterException
TwitterExceptionprotected void onStatus(twitter4j.internal.org.json.JSONObject json)
throws TwitterException
TwitterExceptionprotected void onDirectMessage(twitter4j.internal.org.json.JSONObject json)
throws TwitterException,
twitter4j.internal.org.json.JSONException
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected void onDelete(twitter4j.internal.org.json.JSONObject json)
throws TwitterException,
twitter4j.internal.org.json.JSONException
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected void onLimit(twitter4j.internal.org.json.JSONObject json)
throws TwitterException,
twitter4j.internal.org.json.JSONException
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected void onStallWarning(twitter4j.internal.org.json.JSONObject json)
throws TwitterException,
twitter4j.internal.org.json.JSONException
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected void onScrubGeo(twitter4j.internal.org.json.JSONObject json)
throws TwitterException,
twitter4j.internal.org.json.JSONException
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected void onFriends(twitter4j.internal.org.json.JSONObject json)
throws TwitterException,
twitter4j.internal.org.json.JSONException
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected void onFavorite(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target,
twitter4j.internal.org.json.JSONObject targetObject)
throws TwitterException
TwitterExceptionprotected void onUnfavorite(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target,
twitter4j.internal.org.json.JSONObject targetObject)
throws TwitterException
TwitterExceptionprotected void onRetweet(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target,
twitter4j.internal.org.json.JSONObject targetObject)
throws TwitterException
TwitterExceptionprotected void onFollow(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target)
throws TwitterException
TwitterExceptionprotected void onUnfollow(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target)
throws TwitterException
TwitterExceptionprotected 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
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected 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
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected 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
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected 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
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected void onUserListCreation(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject userList)
throws TwitterException,
twitter4j.internal.org.json.JSONException
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected void onUserListUpdated(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject userList)
throws TwitterException,
twitter4j.internal.org.json.JSONException
TwitterExceptiontwitter4j.internal.org.json.JSONExceptionprotected void onUserListDestroyed(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject userList)
throws TwitterException
TwitterExceptionprotected void onUserUpdate(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target)
throws TwitterException
TwitterExceptionprotected void onBlock(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target)
throws TwitterException
TwitterExceptionprotected void onUnblock(twitter4j.internal.org.json.JSONObject source,
twitter4j.internal.org.json.JSONObject target)
throws TwitterException
TwitterExceptionprotected void onException(java.lang.Exception e)
public void close()
throws java.io.IOException
java.io.IOExceptionprotected Status asStatus(twitter4j.internal.org.json.JSONObject json) throws TwitterException
TwitterExceptionprotected DirectMessage asDirectMessage(twitter4j.internal.org.json.JSONObject json) throws TwitterException
TwitterExceptionprotected long[] asFriendList(twitter4j.internal.org.json.JSONObject json)
throws TwitterException
TwitterExceptionprotected User asUser(twitter4j.internal.org.json.JSONObject json) throws TwitterException
TwitterExceptionprotected UserList asUserList(twitter4j.internal.org.json.JSONObject json) throws TwitterException
TwitterException