Scala Reactive Programming

Extending RxScala HelloWorld with Observer

In the preceding example, we explored only two RxScala components—Observable and Subscription. Now, it's time to explore all three components with the same example. We will use the same project and create a new Scala app for this purpose.

Perform the following steps to develop and explore it:

1. Develop HelloWorldApp as shown here:

RxScalaHelloWorld_With_Observable_Subscription_Observer.scala:

      package com.packt.publishing.rxscala.hello 
 
      import rx.lang.scala.Observable 
      import rx.lang.scala.Observer 
      import scala.language.{implicitConversions, postfixOps} 
 
      object RxScalaHelloWorld_With_Observable_Subscription_Observer  extends App { val helloWorld: String = "Hello RxScala World!" val observable = Observable.from(helloWorld) ...