alexsullivan114
Observable.just("Foo") .map { "Bar" } .filter { it == "Baz" } .doOnNext { print("Bat") } .subscribe { print(it) }