Package tweetoscope.tweetsProducer

Class TweetsProducer

java.lang.Object

tweetoscope.tweetsProducer.TweetsProducer

All Implemented Interfaces:

Runnable, Flow.Publisher<com.twitter.clientlib.model.Tweet>

Direct Known Subclasses:

OfflineTweetsProducer, OnlineTweetsProducer

public abstract class TweetsProducer
extends Object
implements Runnable, Flow.Publisher<com.twitter.clientlib.model.Tweet>

Introduces Tweets into the system. The Tweets might be crafted ones, Tweets read from an archive, or Tweets retrieved live from the Twitter API.

Author:

Virginie Galtier

Field Summary

Fields

Modifier and Type	Field	Description
protected List<Flow.Subscriber<? super com.twitter.clientlib.model.Tweet>>	subscribers	List of objects to notify when a new Tweet is received (downstream components = TweetFilter)

Constructor Summary

Constructors

Constructor	Description
TweetsProducer()

Method Summary

Modifier and Type	Method	Description
void	subscribe(Flow.Subscriber<? super com.twitter.clientlib.model.Tweet> subscriber)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Field Details

subscribers

protected List<Flow.Subscriber<? super com.twitter.clientlib.model.Tweet>> subscribers

List of objects to notify when a new Tweet is received (downstream components = TweetFilter)

Constructor Details

TweetsProducer

public TweetsProducer()

Method Details

subscribe

public void subscribe(Flow.Subscriber<? super com.twitter.clientlib.model.Tweet> subscriber)

Specified by:

subscribe in interface Flow.Publisher<com.twitter.clientlib.model.Tweet>