Jul 20, 2017 · 1 min read
Nice! RxKotlin use a variant of that strategy to achieve the same goal
Observable.from(1,2,3)
.subscribeBy( // named arguments for lambda Subscribers
onNext = { println(it) },
onError = { it.printStackTrace() },
onComplete = { println("Done!") }
)Implementation here
