SAM.kt

import io.reactivex.Observable
import io.reactivex.functions.Consumer

class Foo {
    fun main() {
        Observable.just("foo", "bar").subscribe(this::stringConsumer)
    }

    fun stringConsumer(value: String) {
      println(value)
    }
}