rx-java-simple-1

import io.reactivex.Observable
import io.reactivex.Observer
import io.reactivex.disposables.Disposable
import io.reactivex.schedulers.Schedulers

fun main(args: Array<String>) {
    val data: MutableList<String> = mutableListOf("Andi", "Beni", "Deni", "Fani", "Gita") // Sumber data
    val observer = object : Observer<MutableList<String>> { // Membuat observer
        override fun onNext(p0: MutableList<String>) {
            // Do something
        }

        override fun onSubscribe(p0: Disposable) {
            // Do something
        }

        override fun onComplete() {
            // Do something
        }

        override fun onError(p0: Throwable) {
            // Do something
        }
    }
    val scheduler = Schedulers.io() // Salah satu scheduler
    val observable = Observable.just(data).observeOn(scheduler) // Membuat observable

    observable.subscribe(observer) // compose jadi satu
}