twitter4j

Class SiteStreamsImpl

java.lang.Object

twitter4j.StatusStreamBase

twitter4j.SiteStreamsImpl

All Implemented Interfaces:

StatusStream

final class SiteStreamsImpl
extends StatusStreamBase

Since:

Twitter4J 2.1.8

Author:

Yusuke Yamamoto - yusuke at mac.com

Nested Class Summary

Nested classes/interfaces inherited from class twitter4j.StatusStreamBase

StatusStreamBase.StreamEvent

Field Summary

Fields

Modifier and Type	Field and Description
private StreamController	cs
protected static RawStreamListener[]	EMPTY
private static java.lang.ThreadLocal<java.lang.Long>	forUser

Fields inherited from class twitter4j.StatusStreamBase

CONF, logger

Constructor Summary

Constructors

Constructor and Description
SiteStreamsImpl(Dispatcher dispatcher, HttpResponse response, Configuration conf, StreamController cs)
SiteStreamsImpl(Dispatcher dispatcher, java.io.InputStream stream, Configuration conf, StreamController cs)

Method Summary

Modifier and Type	Method and Description
void	next(StatusListener listener) Reads next status from this stream.
void	next(StreamListener[] listeners, RawStreamListener[] rawStreamListeners)
protected void	onBlock(JSONObject source, JSONObject target, StreamListener[] listeners)
protected void	onClose()
protected void	onDelete(JSONObject json, StreamListener[] listeners)
protected void	onDirectMessage(JSONObject json, StreamListener[] listeners)
void	onDisconnectionNotice(java.lang.String line, StreamListener[] listeners)
void	onException(java.lang.Exception ex, StreamListener[] listeners)
protected void	onFavorite(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
(package private) void	onFavoritedRetweet(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
protected void	onFollow(JSONObject source, JSONObject target, StreamListener[] listeners)
protected void	onFriends(JSONObject json, StreamListener[] listeners)
protected void	onMessage(java.lang.String rawString, RawStreamListener[] listeners)
(package private) void	onMute(JSONObject source, JSONObject target, StreamListener[] listeners)
(package private) void	onQuotedTweet(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
(package private) void	onRetweetedRetweet(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
protected void	onStatus(JSONObject json, StreamListener[] listeners)
protected void	onUnblock(JSONObject source, JSONObject target, StreamListener[] listeners)
protected void	onUnfavorite(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
protected void	onUnfollow(JSONObject source, JSONObject target, StreamListener[] listeners)
(package private) void	onUnmute(JSONObject source, JSONObject target, StreamListener[] listeners)
protected void	onUserDeletion(long target, StreamListener[] listeners)
protected void	onUserListCreation(JSONObject source, JSONObject userList, StreamListener[] listeners)
protected void	onUserListDestroyed(JSONObject source, JSONObject userList, StreamListener[] listeners)
protected void	onUserListMemberAddition(JSONObject addedMember, JSONObject owner, JSONObject userList, StreamListener[] listeners)
protected void	onUserListMemberDeletion(JSONObject deletedMember, JSONObject owner, JSONObject userList, StreamListener[] listeners)
protected void	onUserListSubscription(JSONObject source, JSONObject owner, JSONObject userList, StreamListener[] listeners)
protected void	onUserListUnsubscription(JSONObject source, JSONObject owner, JSONObject userList, StreamListener[] listeners)
protected void	onUserListUpdated(JSONObject source, JSONObject userList, StreamListener[] listeners)
protected void	onUserSuspension(long target, StreamListener[] listeners)
protected void	onUserUpdate(JSONObject source, JSONObject target, StreamListener[] listeners)
protected java.lang.String	parseLine(java.lang.String line)

Methods inherited from class twitter4j.StatusStreamBase

asDirectMessage, asFriendList, asStatus, asUser, asUserList, close, handleNextElement, onException, onLimit, onScrubGeo, onSender, onStallWarning

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

cs

private final StreamController cs

forUser

private static final java.lang.ThreadLocal<java.lang.Long> forUser

EMPTY

protected static final RawStreamListener[] EMPTY

Constructor Detail

SiteStreamsImpl

SiteStreamsImpl(Dispatcher dispatcher,
                java.io.InputStream stream,
                Configuration conf,
                StreamController cs)
         throws java.io.IOException

Throws:

java.io.IOException

SiteStreamsImpl

SiteStreamsImpl(Dispatcher dispatcher,
                HttpResponse response,
                Configuration conf,
                StreamController cs)
         throws java.io.IOException

Throws:

java.io.IOException

Method Detail

parseLine

protected java.lang.String parseLine(java.lang.String line)

Overrides:

parseLine in class StatusStreamBase

onClose

protected void onClose()

Specified by:

onClose in class StatusStreamBase

onMessage

protected void onMessage(java.lang.String rawString,
                         RawStreamListener[] listeners)
                  throws TwitterException

Overrides:

onMessage in class StatusStreamBase

Throws:

TwitterException

onStatus

protected void onStatus(JSONObject json,
                        StreamListener[] listeners)
                 throws TwitterException

Overrides:

onStatus in class StatusStreamBase

Throws:

TwitterException

onDelete

protected void onDelete(JSONObject json,
                        StreamListener[] listeners)
                 throws JSONException

Overrides:

onDelete in class StatusStreamBase

Throws:

JSONException

onDirectMessage

protected void onDirectMessage(JSONObject json,
                               StreamListener[] listeners)
                        throws TwitterException

Overrides:

onDirectMessage in class StatusStreamBase

Throws:

TwitterException

onFriends

protected void onFriends(JSONObject json,
                         StreamListener[] listeners)
                  throws TwitterException,
                         JSONException

Overrides:

onFriends in class StatusStreamBase

Throws:

TwitterException

JSONException

onFavorite

protected void onFavorite(JSONObject source,
                          JSONObject target,
                          JSONObject targetObject,
                          StreamListener[] listeners)
                   throws TwitterException

Overrides:

onFavorite in class StatusStreamBase

Throws:

TwitterException

onUnfavorite

protected void onUnfavorite(JSONObject source,
                            JSONObject target,
                            JSONObject targetObject,
                            StreamListener[] listeners)
                     throws TwitterException

Overrides:

onUnfavorite in class StatusStreamBase

Throws:

TwitterException

onFollow

protected void onFollow(JSONObject source,
                        JSONObject target,
                        StreamListener[] listeners)
                 throws TwitterException

Overrides:

onFollow in class StatusStreamBase

Throws:

TwitterException

onUnfollow

protected void onUnfollow(JSONObject source,
                          JSONObject target,
                          StreamListener[] listeners)
                   throws TwitterException

Overrides:

onUnfollow in class StatusStreamBase

Throws:

TwitterException

onUserListMemberAddition

protected void onUserListMemberAddition(JSONObject addedMember,
                                        JSONObject owner,
                                        JSONObject userList,
                                        StreamListener[] listeners)
                                 throws TwitterException,
                                        JSONException

Overrides:

onUserListMemberAddition in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListMemberDeletion

protected void onUserListMemberDeletion(JSONObject deletedMember,
                                        JSONObject owner,
                                        JSONObject userList,
                                        StreamListener[] listeners)
                                 throws TwitterException,
                                        JSONException

Overrides:

onUserListMemberDeletion in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListSubscription

protected void onUserListSubscription(JSONObject source,
                                      JSONObject owner,
                                      JSONObject userList,
                                      StreamListener[] listeners)
                               throws TwitterException,
                                      JSONException

Overrides:

onUserListSubscription in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListUnsubscription

protected void onUserListUnsubscription(JSONObject source,
                                        JSONObject owner,
                                        JSONObject userList,
                                        StreamListener[] listeners)
                                 throws TwitterException,
                                        JSONException

Overrides:

onUserListUnsubscription in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListCreation

protected void onUserListCreation(JSONObject source,
                                  JSONObject userList,
                                  StreamListener[] listeners)
                           throws TwitterException,
                                  JSONException

Overrides:

onUserListCreation in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListUpdated

protected void onUserListUpdated(JSONObject source,
                                 JSONObject userList,
                                 StreamListener[] listeners)
                          throws TwitterException,
                                 JSONException

Overrides:

onUserListUpdated in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListDestroyed

protected void onUserListDestroyed(JSONObject source,
                                   JSONObject userList,
                                   StreamListener[] listeners)
                            throws TwitterException

Overrides:

onUserListDestroyed in class StatusStreamBase

Throws:

TwitterException

onUserUpdate

protected void onUserUpdate(JSONObject source,
                            JSONObject target,
                            StreamListener[] listeners)
                     throws TwitterException

Overrides:

onUserUpdate in class StatusStreamBase

Throws:

TwitterException

onUserSuspension

protected void onUserSuspension(long target,
                                StreamListener[] listeners)
                         throws TwitterException

Overrides:

onUserSuspension in class StatusStreamBase

Throws:

TwitterException

onUserDeletion

protected void onUserDeletion(long target,
                              StreamListener[] listeners)
                       throws TwitterException

Overrides:

onUserDeletion in class StatusStreamBase

Throws:

TwitterException

onBlock

protected void onBlock(JSONObject source,
                       JSONObject target,
                       StreamListener[] listeners)
                throws TwitterException

Overrides:

onBlock in class StatusStreamBase

Throws:

TwitterException

onUnblock

protected void onUnblock(JSONObject source,
                         JSONObject target,
                         StreamListener[] listeners)
                  throws TwitterException

Overrides:

onUnblock in class StatusStreamBase

Throws:

TwitterException

onRetweetedRetweet

void onRetweetedRetweet(JSONObject source,
                        JSONObject target,
                        JSONObject targetObject,
                        StreamListener[] listeners)
                 throws TwitterException

Overrides:

onRetweetedRetweet in class StatusStreamBase

Throws:

TwitterException

onFavoritedRetweet

void onFavoritedRetweet(JSONObject source,
                        JSONObject target,
                        JSONObject targetObject,
                        StreamListener[] listeners)
                 throws TwitterException

Overrides:

onFavoritedRetweet in class StatusStreamBase

Throws:

TwitterException

onQuotedTweet

void onQuotedTweet(JSONObject source,
                   JSONObject target,
                   JSONObject targetObject,
                   StreamListener[] listeners)
            throws TwitterException

Overrides:

onQuotedTweet in class StatusStreamBase

Throws:

TwitterException

onMute

void onMute(JSONObject source,
            JSONObject target,
            StreamListener[] listeners)
     throws TwitterException

Overrides:

onMute in class StatusStreamBase

Throws:

TwitterException

onUnmute

void onUnmute(JSONObject source,
              JSONObject target,
              StreamListener[] listeners)
       throws TwitterException

Overrides:

onUnmute in class StatusStreamBase

Throws:

TwitterException

onException

public void onException(java.lang.Exception ex,
                        StreamListener[] listeners)

Overrides:

onException in class StatusStreamBase

next

public void next(StatusListener listener)
          throws TwitterException

Description copied from interface: StatusStream

Reads next status from this stream.

Specified by:

next in interface StatusStream

Specified by:

next in class StatusStreamBase

Parameters:

listener - a StatusListener implementation

Throws:

TwitterException - when the end of the stream has been reached.

next

public void next(StreamListener[] listeners,
                 RawStreamListener[] rawStreamListeners)
          throws TwitterException

Specified by:

next in class StatusStreamBase

Throws:

TwitterException

onDisconnectionNotice

public void onDisconnectionNotice(java.lang.String line,
                                  StreamListener[] listeners)

Overrides:

onDisconnectionNotice in class StatusStreamBase