twitter4j

Class StatusStreamImpl

java.lang.Object

twitter4j.StatusStreamBase

twitter4j.StatusStreamImpl

All Implemented Interfaces:

StatusStream

Direct Known Subclasses:

UserStreamImpl

 class StatusStreamImpl
extends StatusStreamBase

StatusStream implementation. This class is NOT intended to be extended but left non-final for the ease of mock testing.

Since:

Twitter4J 2.1.2

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
protected static RawStreamListener[]	EMPTY
protected java.lang.String	line

Fields inherited from class twitter4j.StatusStreamBase

CONF, dispatcher, factory, logger

Constructor Summary

Constructors

Constructor and Description
StatusStreamImpl(twitter4j.internal.async.Dispatcher dispatcher, twitter4j.internal.http.HttpResponse response, Configuration conf)
StatusStreamImpl(twitter4j.internal.async.Dispatcher dispatcher, java.io.InputStream stream, Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
void	next(StatusListener listener) Reads next status from this stream.
void	next(StreamListener[] listeners, RawStreamListener[] rawStreamListeners)
protected void	onDelete(twitter4j.internal.org.json.JSONObject json, StreamListener[] listeners)
void	onException(java.lang.Exception e, StreamListener[] listeners)
protected void	onLimit(twitter4j.internal.org.json.JSONObject json, StreamListener[] listeners)
protected void	onMessage(java.lang.String rawString, RawStreamListener[] listeners)
protected void	onScrubGeo(twitter4j.internal.org.json.JSONObject json, StreamListener[] listeners)
protected void	onStallWarning(twitter4j.internal.org.json.JSONObject json, StreamListener[] listeners)
protected void	onStatus(twitter4j.internal.org.json.JSONObject json, StreamListener[] listeners)
protected java.lang.String	parseLine(java.lang.String line)

Methods inherited from class twitter4j.StatusStreamBase

asDirectMessage, asFriendList, asStatus, asUser, asUserList, close, handleNextElement, onBlock, onDirectMessage, onDisconnectionNotice, onException, onFavorite, onFollow, onFriends, onSender, onUnblock, onUnfavorite, onUnfollow, onUserListCreation, onUserListDestroyed, onUserListMemberAddition, onUserListMemberDeletion, onUserListSubscription, onUserListUnsubscription, onUserListUpdated, onUserUpdate

Methods inherited from class java.lang.Object

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

Field Detail

line

protected java.lang.String line

EMPTY

protected static final RawStreamListener[] EMPTY

Constructor Detail

StatusStreamImpl

StatusStreamImpl(twitter4j.internal.async.Dispatcher dispatcher,
                java.io.InputStream stream,
                Configuration conf)
           throws java.io.IOException

Throws:

java.io.IOException

StatusStreamImpl

StatusStreamImpl(twitter4j.internal.async.Dispatcher dispatcher,
                twitter4j.internal.http.HttpResponse response,
                Configuration conf)
           throws java.io.IOException

Throws:

java.io.IOException

Method Detail

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

parseLine

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

Overrides:

parseLine 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(twitter4j.internal.org.json.JSONObject json,
            StreamListener[] listeners)
                 throws TwitterException

Overrides:

onStatus in class StatusStreamBase

Throws:

TwitterException

onDelete

protected void onDelete(twitter4j.internal.org.json.JSONObject json,
            StreamListener[] listeners)
                 throws TwitterException,
                        twitter4j.internal.org.json.JSONException

Overrides:

onDelete in class StatusStreamBase

Throws:

TwitterException

twitter4j.internal.org.json.JSONException

onLimit

protected void onLimit(twitter4j.internal.org.json.JSONObject json,
           StreamListener[] listeners)
                throws TwitterException,
                       twitter4j.internal.org.json.JSONException

Overrides:

onLimit in class StatusStreamBase

Throws:

TwitterException

twitter4j.internal.org.json.JSONException

onStallWarning

protected void onStallWarning(twitter4j.internal.org.json.JSONObject json,
                  StreamListener[] listeners)
                       throws TwitterException,
                              twitter4j.internal.org.json.JSONException

Overrides:

onStallWarning in class StatusStreamBase

Throws:

TwitterException

twitter4j.internal.org.json.JSONException

onScrubGeo

protected void onScrubGeo(twitter4j.internal.org.json.JSONObject json,
              StreamListener[] listeners)
                   throws TwitterException,
                          twitter4j.internal.org.json.JSONException

Overrides:

onScrubGeo in class StatusStreamBase

Throws:

TwitterException

twitter4j.internal.org.json.JSONException

onException

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

Overrides:

onException in class StatusStreamBase