Basic RxJava-Scala examples

RxScalaSamples.scala

  @Test def runTests() {
    // using closure
    Observable.toObservable("1", "2", "3")
      .take(2)
      .subscribe((callback: String) => {
          println(callback)
      })
      
    // using Map of closures
    Observable.toObservable("1", "2", "3")
      .take(2)
      .subscribe(Map(
        "onNext" -> ((callback: String) => {
          println(callback)
        })))
  }