RedisPrinter

Value Members

1. final def !=(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

2. final def !=(arg0: Any): Boolean

   Definition Classes

   Any

3. final def ##(): Int

   Definition Classes

   AnyRef → Any

4. final def ==(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

5. final def ==(arg0: Any): Boolean

   Definition Classes

   Any

6. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

8. def db: Int

   The Redis db.

   The Redis db.

   Definition Classes

   RedisPrinter → RedisScanTweets

9. final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

10. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

11. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

12. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

13. def handleException(exception: Throwable): Unit

    Gets called when an exception occurred during providing the Tweets.

    Gets called when an exception occurred during providing the Tweets. This will be a fatal exception, and tweets will not continue to flow after this exception occurred.

    exception

    the fatal exception

    Definition Classes

    PrintText → TweetConsumer

14. def hashCode(): Int

    Definition Classes

    AnyRef → Any

15. def host: String

    The hostname of the Redis server.

    The hostname of the Redis server.

    Definition Classes

    RedisPrinter → RedisScanTweets

16. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

17. final def iterable: Iterable[String]

    Uses the 2.8 Redis SCAN API to obtain Tweets.

    Uses the 2.8 Redis SCAN API to obtain Tweets.

    returns

    an Iterable of Strings, where every String is the JSON representation on a bbuzz.Tweet

    Definition Classes

    RedisScanTweets → FromStringIterable

18. final def main(args: Array[String]): Unit

    Definition Classes

    TweetStreaming

19. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

20. final def notify(): Unit

    Definition Classes

    AnyRef

21. final def notifyAll(): Unit

    Definition Classes

    AnyRef

22. final def onCompleted(): Unit

    Definition Classes

    TweetConsumer → Observer

23. final def onError(error: Throwable): Unit

    Definition Classes

    TweetConsumer → Observer

24. final def onNext(value: Tweet): Unit

    Definition Classes

    TweetConsumer → Observer

25. def onTweet(tweet: Tweet): Unit

    Gets called for every tweet that is pulled from the bbuzz.TweetProvider.

    Gets called for every tweet that is pulled from the bbuzz.TweetProvider. This method should not block and complete quickly.

    tweet

    a new bbuzz.Tweet

    Definition Classes

    PrintText → TweetConsumer

26. def port: Int

    The port of the Redis server.

    The port of the Redis server.

    Definition Classes

    RedisPrinter → RedisScanTweets

27. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

28. def toString(): String

    Definition Classes

    AnyRef → Any

29. final def tweets: TweetObservable

    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

    returns

    an Observable of Tweets

    Definition Classes

    FromStringIterable → TweetProvider

30. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

31. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

32. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )