[kotlin]애기 걸음, reactive 구구단

프로그램 처음 배울 때 다들 한 번쯤 해보는 구구단 코딩을 해봤습니다 ㅎ

import io.reactivex.rxjava3.core.Observable
import io.reactivex.rxjava3.kotlin.subscribeBy

fun main(args: Array<String>) {
    val observable = Observable.range(2,8)

    observable.flatMap {
       number ->
       Observable.create<String> {
           it.onNext("$number Times Table")
           for (i in 1..9) {
               it.onNext(" $number * $i = ${i * number}")
           }
           it.onComplete()
       }
    }.subscribeBy (
        onNext = {
           item -> println("$item")
        },
        onComplete = {
            println("Complete")
        }
    )
}