twitter4j

Class UserStreamImpl

java.lang.Object

twitter4j.StatusStreamBase

twitter4j.StatusStreamImpl

twitter4j.UserStreamImpl

All Implemented Interfaces:

StatusStream, UserStream

final class UserStreamImpl
extends StatusStreamImpl
implements UserStream

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 inherited from class twitter4j.StatusStreamImpl

EMPTY, line

Fields inherited from class twitter4j.StatusStreamBase

CONF, logger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	next(UserStreamListener listener) Reads next element from this stream.
protected void	onBlock(JSONObject source, JSONObject target, StreamListener[] listeners)
protected void	onDirectMessage(JSONObject json, 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	onQuotedTweet(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
(package private) void	onRetweetedRetweet(JSONObject source, JSONObject target, JSONObject targetObject, StreamListener[] listeners)
protected void	onScrubGeo(JSONObject json, StreamListener[] listeners)
protected void	onSender(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	onUserDeletion(long target, StreamListener[] listeners)
protected void	onUserListCreation(JSONObject source, JSONObject target, StreamListener[] listeners)
protected void	onUserListDestroyed(JSONObject source, JSONObject target, StreamListener[] listeners)
protected void	onUserListMemberAddition(JSONObject addedMember, JSONObject owner, JSONObject target, StreamListener[] listeners)
protected void	onUserListMemberDeletion(JSONObject deletedMember, JSONObject owner, JSONObject target, StreamListener[] listeners)
protected void	onUserListSubscription(JSONObject source, JSONObject owner, JSONObject target, StreamListener[] listeners)
protected void	onUserListUnsubscription(JSONObject source, JSONObject owner, JSONObject target, StreamListener[] listeners)
protected void	onUserListUpdated(JSONObject source, JSONObject target, StreamListener[] listeners)
protected void	onUserSuspension(long target, StreamListener[] listeners)
protected void	onUserUpdate(JSONObject source, JSONObject target, StreamListener[] listeners)

Methods inherited from class twitter4j.StatusStreamImpl

next, next, onClose, onDelete, onException, onLimit, onMessage, onStallWarning, onStatus, parseLine

Methods inherited from class twitter4j.StatusStreamBase

asDirectMessage, asFriendList, asStatus, asUser, asUserList, close, handleNextElement, onDisconnectionNotice, onException, onMute, onUnmute

Methods inherited from class java.lang.Object

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

Methods inherited from interface twitter4j.UserStream

close

Methods inherited from interface twitter4j.StatusStream

next

Constructor Detail

UserStreamImpl

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

Throws:

java.io.IOException

UserStreamImpl

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

Throws:

java.io.IOException

Method Detail

next

public void next(UserStreamListener listener)
          throws TwitterException

Description copied from interface: UserStream

Reads next element from this stream.

Specified by:

next in interface UserStream

Parameters:

listener - a UserStreamListener implementation

Throws:

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

onSender

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

Overrides:

onSender in class StatusStreamBase

Throws:

TwitterException

onDirectMessage

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

Overrides:

onDirectMessage in class StatusStreamBase

Throws:

TwitterException

JSONException

onScrubGeo

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

Overrides:

onScrubGeo in class StatusStreamImpl

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 target,
                                        StreamListener[] listeners)
                                 throws TwitterException,
                                        JSONException

Overrides:

onUserListMemberAddition in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListMemberDeletion

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

Overrides:

onUserListMemberDeletion in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListSubscription

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

Overrides:

onUserListSubscription in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListUnsubscription

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

Overrides:

onUserListUnsubscription in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListCreation

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

Overrides:

onUserListCreation in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListUpdated

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

Overrides:

onUserListUpdated in class StatusStreamBase

Throws:

TwitterException

JSONException

onUserListDestroyed

protected void onUserListDestroyed(JSONObject source,
                                   JSONObject target,
                                   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

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

Overrides:

onQuotedTweet in class StatusStreamBase

Throws:

TwitterException