rxjava.kt

// Without it
ObservableHttp.createRequest(HttpAsyncMethods.createGet(url), client)
                .toObservable()
                .flatMap({ response -> response.getContent().map {
                        byte ->
                        String(byte)
                    }
                })
                .toBlocking()
                .forEach {
                    data -> println(data)
                }
    }
    
// With it
ObservableHttp.createRequest(HttpAsyncMethods.createGet(url), client)
                .toObservable()
                .flatMap({
                    it.getContent().map {
                        String(it)
                    }
                })
                .toBlocking()
                .forEach {
                    println(it)
                }