twitter4j

Class StatusStreamBase

java.lang.Object

twitter4j.StatusStreamBase

All Implemented Interfaces:

StatusStream

Direct Known Subclasses:

SiteStreamsImpl, StatusStreamImpl

abstract class StatusStreamBase
extends java.lang.Object
implements StatusStream

Since:

Twitter4J 2.1.8

Author:

Yusuke Yamamoto - yusuke at mac.com

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	StatusStreamBase.StreamEvent

Field Summary

Fields

Modifier and Type	Field and Description
private java.io.BufferedReader	br
(package private) Configuration	CONF
private Dispatcher	dispatcher
private ObjectFactory	factory
private java.io.InputStream	is
(package private) static Logger	logger
private HttpResponse	response
private boolean	streamAlive

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
(package private) DirectMessage	asDirectMessage(JSONObject json)
(package private) long[]	asFriendList(JSONObject json)
(package private) Status	asStatus(JSONObject json)
(package private) User	asUser(JSONObject json)
(package private) UserList	asUserList(JSONObject json)
void	close()
(package private) void	handleNextElement(StreamListener[] listeners, RawStreamListener[] rawStreamListeners)
abstract void	next(StatusListener listener) Reads next status from this stream.
abstract void	next(StreamListener[] listeners, RawStreamListener[] rawStreamListeners)
(package private) void	onBlock(JSONObject source, JSONObject target, StreamListener[] listeners)
protected abstract void	onClose()
(package private) void	onDelete(JSONObject json, StreamListener[] listeners)
(package private) void	onDirectMessage(JSONObject json, StreamListener[] listeners)
(package private) void	onDisconnectionNotice(java.lang.String line, StreamListener[] listeners)
(package private) void	onException(java.lang.Exception e, StreamListener[] listeners)
void	onException(java.lang.Exception e, StreamListener[] listeners, RawStreamListener[] rawStreamListeners)
(package private) void	onFavorite(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
(package private) void	onFavoritedRetweet(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
(package private) void	onFollow(JSONObject source, JSONObject target, StreamListener[] listeners)
(package private) void	onFriends(JSONObject json, StreamListener[] listeners)
(package private) void	onLimit(JSONObject json, StreamListener[] listeners)
(package private) 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)
(package private) void	onScrubGeo(JSONObject json, StreamListener[] listeners)
(package private) void	onSender(JSONObject json, StreamListener[] listeners)
(package private) void	onStallWarning(JSONObject json, StreamListener[] listeners)
(package private) void	onStatus(JSONObject json, StreamListener[] listeners)
(package private) void	onUnblock(JSONObject source, JSONObject target, StreamListener[] listeners)
(package private) void	onUnfavorite(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
(package private) void	onUnfollow(JSONObject source, JSONObject target, StreamListener[] listeners)
(package private) void	onUnmute(JSONObject source, JSONObject target, StreamListener[] listeners)
(package private) void	onUserDeletion(long target, StreamListener[] listeners)
(package private) void	onUserListCreation(JSONObject source, JSONObject userList, StreamListener[] listeners)
(package private) void	onUserListDestroyed(JSONObject source, JSONObject userList, StreamListener[] listeners)
(package private) void	onUserListMemberAddition(JSONObject addedMember, JSONObject owner, JSONObject userList, StreamListener[] listeners)
(package private) void	onUserListMemberDeletion(JSONObject deletedMember, JSONObject owner, JSONObject userList, StreamListener[] listeners)
(package private) void	onUserListSubscription(JSONObject source, JSONObject owner, JSONObject userList, StreamListener[] listeners)
(package private) void	onUserListUnsubscription(JSONObject source, JSONObject owner, JSONObject userList, StreamListener[] listeners)
(package private) void	onUserListUpdated(JSONObject source, JSONObject userList, StreamListener[] listeners)
(package private) void	onUserSuspension(long target, StreamListener[] listeners)
(package private) void	onUserUpdate(JSONObject source, JSONObject target, StreamListener[] listeners)
(package private) java.lang.String	parseLine(java.lang.String line)

Methods inherited from class java.lang.Object

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

Field Detail

logger

static final Logger logger

streamAlive

private boolean streamAlive

br

private java.io.BufferedReader br

is

private java.io.InputStream is

response

private HttpResponse response

dispatcher

private final Dispatcher dispatcher

CONF

final Configuration CONF

factory

private ObjectFactory factory

Constructor Detail

StatusStreamBase

StatusStreamBase(Dispatcher dispatcher,
                 java.io.InputStream stream,
                 Configuration conf)
          throws java.io.IOException

Throws:

java.io.IOException

StatusStreamBase

StatusStreamBase(Dispatcher dispatcher,
                 HttpResponse response,
                 Configuration conf)
          throws java.io.IOException

Throws:

java.io.IOException

Method Detail

parseLine

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

handleNextElement

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

Throws:

TwitterException

onMessage

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

Throws:

TwitterException

onSender

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

Throws:

TwitterException

onStatus

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

Throws:

TwitterException

onDirectMessage

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

Throws:

TwitterException

JSONException

onDelete

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

Throws:

TwitterException

JSONException

onLimit

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

Throws:

TwitterException

JSONException

onStallWarning

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

Throws:

TwitterException

JSONException

onScrubGeo

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

Throws:

TwitterException

JSONException

onFriends

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

Throws:

TwitterException

JSONException

onFavorite

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

Throws:

TwitterException

onUnfavorite

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

Throws:

TwitterException

onFollow

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

Throws:

TwitterException

onUnfollow

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

Throws:

TwitterException

onUserListMemberAddition

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

Throws:

TwitterException

JSONException

onUserListMemberDeletion

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

Throws:

TwitterException

JSONException

onUserListSubscription

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

Throws:

TwitterException

JSONException

onUserListUnsubscription

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

Throws:

TwitterException

JSONException

onUserListCreation

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

Throws:

TwitterException

JSONException

onUserListUpdated

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

Throws:

TwitterException

JSONException

onUserListDestroyed

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

Throws:

TwitterException

onUserUpdate

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

Throws:

TwitterException

onUserDeletion

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

Throws:

TwitterException

onUserSuspension

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

Throws:

TwitterException

onBlock

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

Throws:

TwitterException

onUnblock

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

Throws:

TwitterException

onRetweetedRetweet

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

Throws:

TwitterException

onFavoritedRetweet

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

Throws:

TwitterException

onQuotedTweet

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

Throws:

TwitterException

onMute

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

Throws:

TwitterException

onUnmute

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

Throws:

TwitterException

onDisconnectionNotice

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

onException

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

onClose

protected abstract void onClose()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface StatusStream

Throws:

java.io.IOException

asStatus

Status asStatus(JSONObject json)
         throws TwitterException

Throws:

TwitterException

asDirectMessage

DirectMessage asDirectMessage(JSONObject json)
                       throws TwitterException

Throws:

TwitterException

asFriendList

long[] asFriendList(JSONObject json)
             throws TwitterException

Throws:

TwitterException

asUser

User asUser(JSONObject json)
     throws TwitterException

Throws:

TwitterException

asUserList

UserList asUserList(JSONObject json)
             throws TwitterException

Throws:

TwitterException

next

public abstract void next(StatusListener listener)
                   throws TwitterException

Description copied from interface: StatusStream

Reads next status from this stream.

Specified by:

next in interface StatusStream

Parameters:

listener - a StatusListener implementation

Throws:

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

next

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

Throws:

TwitterException

onException

public void onException(java.lang.Exception e,
                        StreamListener[] listeners,
                        RawStreamListener[] rawStreamListeners)