RxJava 学习笔记4 - lift()

fun start() { Observable.create<String> { println("onSubscribe") it.onNext("1") }.lift<Int> { subscriber -> println("lift") //感觉像是自己手动实现 map return@lift

>>阅读原文<<