Simple RxKotlin

rxKotlin.kt

Observable.fromArray(1,2,3,4)
  .subscribeBy(
      onNext = {
          println(it)
      },
      onComplete = {
          println("Completed")
      },
      onError = {
          println(it.message)
      }
    )
}