/** First prints "one dish", then "two dish" */ fun printRxJavaStuff() { Observable.from(asList("one fish", "two fish", "red fish", "blue fish")) .filter { it.contains("one") || it.contains("two") } .map { it.replace("fish", "dish") } .subscribe( { Timber.v(s) } ) // First prints "one dish", then "two dish" }