Uses the 2.8 Redis SCAN API to obtain Tweets.
Uses the 2.8 Redis SCAN API to obtain Tweets.
an Iterable of Strings, where every String is the JSON representation on a bbuzz.Tweet
Tweets are provided as an rx.lang.scala.Observable.
Tweets are provided as an rx.lang.scala.Observable.
You can implement this in any way you like, though you might want to have a look at the companions object's helper traits.
This Observable
will be consumed by a bbuzz.TweetConsumer
an Observable
of Tweets
Provides tweets by scanning a Redis db.
This uses the 2.8 SCAN feature. All entries in the provided db should only be simple values (SET/GET) and contain valid tweets.