Kotlin: Как одновременно выводить ArrayList из Rxjava

Question

Я хочу печатать во время ArrayList.

До:

class ExampleUnitTest {
    @Test
    fun test(){
        val stringArray = arrayOf("10", "20", "30", "40", "30", "20", "10", "5", "20", "30", "20", "30").map { it }
        println(stringArray.toString())
    }
}

# output is :
[10, 20, 30, 40, 30, 20, 10, 5, 20, 30, 20, 30]

После:

# I Want to output Like this :
10, 20, 30, 40, 30, 20, 10, 5, 20, 30, 20, 30

Как я могу выполнить это кодирование с помощью Reactivex Java (Rx Java)

# something like... e.g..
Observable ...{
   ... ...
}.subscribeOn(Schedulers.io())
.subscribe({
   ... ...
})

Answer 1

Я справился с проблемой сам!

val sample = listOf("a","b","c","d","e","f","g")
        Observable.fromIterable(sample.withIndex())
            .subscribeOn(Schedulers.io())
            .subscribe({ (index, item) ->
                print(if(sample.size > index) item else "$item, ")
                println()
            },
            { e -> e.printStackTrace() },
            { println("finished!") }
        )