twitter4j

Class StatusStreamImpl

java.lang.Object

twitter4j.StatusStreamImpl

All Implemented Interfaces:

StatusStream, UserStream

 class StatusStreamImpl
extends java.lang.Object
implements StatusStream, UserStream

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

Field Summary

Fields

Modifier and Type	Field and Description
private java.io.BufferedReader	br
private java.io.InputStream	is
private static twitter4j.internal.logging.Logger	logger
private twitter4j.internal.http.HttpResponse	response
private boolean	streamAlive

Constructor Summary

Constructors

Constructor and Description
StatusStreamImpl(twitter4j.internal.http.HttpResponse response)
StatusStreamImpl(java.io.InputStream stream)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
(package private) Status	extractTargetObject(twitter4j.internal.org.json.JSONObject json)
private void	handleNextElement(java.util.List<StatusListener> listeners)
(package private) void	next(java.util.List<StatusListener> listeners)
void	next(StatusListener listener) Reads next status from this stream.
void	next(UserStreamListener listener) Reads next element from this stream.

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final twitter4j.internal.logging.Logger logger

streamAlive

private boolean streamAlive

br

private java.io.BufferedReader br

is

private java.io.InputStream is

response

private twitter4j.internal.http.HttpResponse response

Constructor Detail

StatusStreamImpl

StatusStreamImpl(java.io.InputStream stream)
           throws java.io.IOException

Throws:

java.io.IOException

StatusStreamImpl

StatusStreamImpl(twitter4j.internal.http.HttpResponse response)
           throws java.io.IOException

Throws:

java.io.IOException

Method Detail

next

public void next(UserStreamListener listener)
          throws TwitterException

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.

next

public void next(StatusListener listener)
          throws TwitterException

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

void next(java.util.List<StatusListener> listeners)
    throws TwitterException

Throws:

TwitterException

handleNextElement

private void handleNextElement(java.util.List<StatusListener> listeners)
                        throws TwitterException

Throws:

TwitterException

extractTargetObject

Status extractTargetObject(twitter4j.internal.org.json.JSONObject json)
                     throws twitter4j.internal.org.json.JSONException,
                            TwitterException

Throws:

twitter4j.internal.org.json.JSONException

TwitterException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface StatusStream

Specified by:

close in interface UserStream

Throws:

java.io.IOException