Kotlin有点用力过猛了

public fun readBlogHtml(blog: String) : Observable<String> {
    return Observable.just(blog)
                    .map{ blog -> assembleUrl(blog) }
                    .flatMap { url -> readHtml(url) }
}

public fun readHtml(url: String) : Observable<String> {
    return Observable.create<String> {
        subscriber -> subscriber.onNext(URL(url).readText()); subscriber.onCompleted()
    }
}

public fun readBlogHtml(blog: String) : Observable<String> = Observable.just(blog)
                    .map { blog -> assembleUrl(blog) }
                    .map { url -> readHtml(url) }

private fun assembleUrl(blog: String?): String = "http://$blog.tumblr.com/page/"

public fun readHtml(url: String) : String = URL(url).readText()

fun test() {
    async {
        val html = readBlogHtml("blog")
        uiThread { update(html) }
    }
}

public fun readBlogHtml(blog: String) : String = readHtml(assembleUrl(blog))

private fun assembleUrl(blog: String?): String = "http://$blog.tumblr.com/page/"

public fun readHtml(url: String) : String = URL(url).readText()