RX + Kotlin

easyhttp-rx.kt

    fun get(url: String, headers: Headers = Headers()): Observable<Response> {

        //return getWithExplicitClass(url, headers)!!
        //return getWithAnonymousClass(url, headers)!!
        //return getWithInlineUsingObsoleteSubscribeFunc(url, headers)!!
        return getWithFailingInlineFunction(url, headers)!!
    }

    fun getWithFailingInlineFunction(url: String, headers: Headers = Headers()) : Observable<Response>? {
        // This fails. Looks like a bug in Kotlin: http://youtrack.jetbrains.com/issue/KT-4598
        return Observable.create(OnSubscribe<Response> { (it : Subscriber<in Response>?) ->
            get(url, headers, {
                it?.onNext(this)
                it?.onCompleted()
            })
        })
    }

    fun getWithInlineUsingObsoleteSubscribeFunc(url: String, headers: Headers = Headers()) : Observable<Response>? {
        return Observable.create(OnSubscribeFunc<Response> {
            get(url, headers, {
                it?.onNext(this)
                it?.onCompleted()
            })
            Subscriptions.empty()
        })
    }

    fun getWithAnonymousClass(url: String, headers: Headers = Headers()) : Observable<Response>? {
        return Observable.create(object : OnSubscribe<Response> {
            override fun call(s: Subscriber<in Response>?){
                get (url, headers, {
                    s?.onNext(this)
                    s?.onCompleted()
                })
            }
        })
    }

    fun getWithExplicitClass(url: String, headers: Headers = Headers()) : Observable<Response>? {
        return Observable.create(Foo(url, headers))
    }

    // Needs to be inner to get access to EasyHttp.get
    inner class Foo(val url: String, val headers: Headers) : OnSubscribe<Response> {
        override fun call(s: Subscriber<in Response>?) {
            get(url, headers, {
                s?.onNext(this)
                s?.onCompleted()
            })
        }
    }