public interface TwitterStream extends OAuthSupport, TwitterBase
Modifier and Type | Method and Description |
---|---|
void |
addConnectionLifeCycleListener(ConnectionLifeCycleListener listener)
Adds a ConnectionLifeCycleListener
|
void |
addListener(twitter4j.StreamListener listener) |
void |
cleanUp()
shutdown internal stream consuming thread
|
void |
clearListeners()
clear status listeners
|
void |
filter(FilterQuery query)
Start consuming public statuses that match one or more filter predicates.
|
void |
filter(String... track)
Start consuming public statuses that match the filter predicate.
|
void |
firehose(int count)
Starts listening on all public statuses.
|
void |
links(int count)
Starts listening on all public statuses containing links.
|
TwitterStream |
onException(Consumer<Exception> action) |
TwitterStream |
onStatus(Consumer<Status> action) |
void |
removeListener(twitter4j.StreamListener listener) |
void |
replaceListener(twitter4j.StreamListener toBeRemoved,
twitter4j.StreamListener toBeAdded)
replace existing listener
|
void |
retweet()
Starts listening on all retweets.
|
void |
sample()
Starts listening on random sample of all public statuses.
|
void |
sample(String language)
Starts listening on random sample of all public statuses.
|
void |
shutdown()
Shuts down internal dispatcher thread shared by all TwitterStream instances.
|
StreamController |
site(boolean withFollowings,
long... follow)
Site Streams, a new feature on the Streaming API, is now available for beta testing.
|
void |
user()
User Streams provides real-time updates of all data needed to update a desktop application display.
|
void |
user(String... track)
User Streams provides real-time updates of all data needed to update a desktop application display.
|
getOAuthAccessToken, getOAuthAccessToken, getOAuthAccessToken, getOAuthAccessToken, getOAuthAccessToken, getOAuthRequestToken, getOAuthRequestToken, getOAuthRequestToken, getOAuthRequestToken, setOAuthAccessToken, setOAuthConsumer
addRateLimitStatusListener, getAuthorization, getConfiguration, getId, getScreenName, onRateLimitReached, onRateLimitStatus
void addConnectionLifeCycleListener(ConnectionLifeCycleListener listener)
listener
- listener to be addedvoid addListener(twitter4j.StreamListener listener)
listener
- listener to addTwitterStream onStatus(Consumer<Status> action)
action
- action when receiving StatusTwitterStream onException(Consumer<Exception> action)
action
- action when receiving TwitterExceptionvoid removeListener(twitter4j.StreamListener listener)
listener
- listener to removevoid clearListeners()
void replaceListener(twitter4j.StreamListener toBeRemoved, twitter4j.StreamListener toBeAdded)
toBeRemoved
- listener to be removedtoBeAdded
- listener to be addedvoid firehose(int count)
count
- Indicates the number of previous statuses to stream before transitioning to the live stream.StatusStream
,
Streaming API Methods statuses/firehosevoid links(int count)
count
- Indicates the number of previous statuses to stream before transitioning to the live stream.StatusStream
,
Streaming API Methods statuses/linksvoid retweet()
StatusStream
,
Streaming API Methods statuses/retweetvoid sample()
StatusStream
,
Streaming API: Methods statuses/samplevoid sample(String language)
Only samples Tweets written in the given language.
language
- language to be sampledStatusStream
,
Streaming API: Methods statuses/samplevoid user()
IllegalStateException
- when non-UserStreamListener is set, or no listener is setvoid user(String... track)
track
- keywords to trackIllegalStateException
- when non-UserStreamListener is set, or no listener is setStreamController site(boolean withFollowings, long... follow)
withFollowings
- whether to receive status updates from people followingfollow
- an array of users to include in the streamvoid filter(FilterQuery query)
query
- Filter queryStatusStream
,
Streaming API Methods statuses/filtervoid filter(String... track)
track
- words to be filteredvoid cleanUp()
void shutdown()
Copyright © 2016. All Rights Reserved.