Wrapping Okhttp with RxJava

RxOkhttp.kt

object RxOkhttp {
    private val client = OkHttpClient()

    operator fun get(request: Request): Observable<Response> {
        return Observable.defer(Callable<ObservableSource<out Response>> {
            try {
                val response = client.newCall(request).execute()
                return@Callable Observable.just(response)
            } catch (e: IOException) {
                return@Callable Observable.error<Response>(e)
            }
        })
    }
}