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
protected Configuration	CONF
protected Dispatcher	dispatcher
protected ObjectFactory	factory
private java.io.InputStream	is
protected 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
protected DirectMessage	asDirectMessage(JSONObject json)
protected long[]	asFriendList(JSONObject json)
protected Status	asStatus(JSONObject json)
protected User	asUser(JSONObject json)
protected UserList	asUserList(JSONObject json)
void	close()
protected void	handleNextElement(StreamListener[] listeners, RawStreamListener[] rawStreamListeners)
abstract void	next(StatusListener listener) Reads next status from this stream.
abstract void	next(StreamListener[] listeners, RawStreamListener[] rawStreamListeners)
protected void	onBlock(JSONObject source, JSONObject target, StreamListener[] listeners)
protected void	onDelete(JSONObject json, StreamListener[] listeners)
protected void	onDirectMessage(JSONObject json, StreamListener[] listeners)
protected void	onDisconnectionNotice(java.lang.String line, StreamListener[] listeners)
protected void	onException(java.lang.Exception e, StreamListener[] listeners)
void	onException(java.lang.Exception e, StreamListener[] listeners, RawStreamListener[] rawStreamListeners)
protected void	onFavorite(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	onLimit(JSONObject json, StreamListener[] listeners)
protected void	onMessage(java.lang.String rawString, RawStreamListener[] listeners)
protected void	onScrubGeo(JSONObject json, StreamListener[] listeners)
protected void	onSender(JSONObject json, StreamListener[] listeners)
protected void	onStallWarning(JSONObject json, 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)
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	onUserUpdate(JSONObject source, JSONObject target, StreamListener[] listeners)
protected 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

protected 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

protected final Dispatcher dispatcher

CONF

protected final Configuration CONF

factory

protected 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

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

handleNextElement

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

Throws:

TwitterException

onMessage

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

Throws:

TwitterException

onSender

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

Throws:

TwitterException

onStatus

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

Throws:

TwitterException

onDirectMessage

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

Throws:

TwitterException

JSONException

onDelete

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

Throws:

TwitterException

JSONException

onLimit

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

Throws:

TwitterException

JSONException

onStallWarning

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

Throws:

TwitterException

JSONException

onScrubGeo

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

Throws:

TwitterException

JSONException

onFriends

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

Throws:

TwitterException

JSONException

onFavorite

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

Throws:

TwitterException

onUnfavorite

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

Throws:

TwitterException

onFollow

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

Throws:

TwitterException

onUnfollow

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

Throws:

TwitterException

onUserListMemberAddition

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

Throws:

TwitterException

JSONException

onUserListMemberDeletion

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

Throws:

TwitterException

JSONException

onUserListSubscription

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

Throws:

TwitterException

JSONException

onUserListUnsubscription

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

Throws:

TwitterException

JSONException

onUserListCreation

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

Throws:

TwitterException

JSONException

onUserListUpdated

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

Throws:

TwitterException

JSONException

onUserListDestroyed

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

Throws:

TwitterException

onUserUpdate

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

Throws:

TwitterException

onBlock

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

Throws:

TwitterException

onUnblock

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

Throws:

TwitterException

onDisconnectionNotice

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

onException

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

close

public void close()
           throws java.io.IOException

Specified by:

close in interface StatusStream

Throws:

java.io.IOException

asStatus

protected Status asStatus(JSONObject json)
                   throws TwitterException

Throws:

TwitterException

asDirectMessage

protected DirectMessage asDirectMessage(JSONObject json)
                                 throws TwitterException

Throws:

TwitterException

asFriendList

protected long[] asFriendList(JSONObject json)
                       throws TwitterException

Throws:

TwitterException

asUser

protected User asUser(JSONObject json)
               throws TwitterException

Throws:

TwitterException

asUserList

protected 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)