rx-java-simple-2

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")
    Observable
            .just(data)
            .observeOn(Schedulers.io())
            .subscribe(
                    {
                        // Do on next
                    },
                    {
                        // Do on error

                    },
                    {
                        // Do on complete
                    }
            )
}