Simple RxJava Example

simple-rxjava-example.kt

    //Observable
    val getObservable = Observable.just("X", "Y", "Z")

    //Observer
    val getObserver = object : Observer<String> {
        override fun onComplete() {
            println("onComplete")
        }

        override fun onSubscribe(d: Disposable) {
            println("onSubscribe")
        }

        override fun onNext(t: String) {
            println("onNext: $t")
        }

        override fun onError(e: Throwable) {
            println("onError")
        }
    }

    //Subscription
    getObservable
        .subscribe(getObserver)