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