Creating a rx.Observable from a function

observable.kt

import rx.Observer
import rx.Subscription
import rx.Observable
import rx.util.functions.*


fun<T> Function1<Observer<T>, Subscription>.asObservable(): Observable<T> {
    return Observable.create(Func1<Observer<T>, Subscription>{
        this(it!!)
    })!!
}

private fun customObservableNonBlocking(): Observable<String> {
    return {(observer: Observer<String>) ->
        val t = Thread(Runnable{
            for(i in 0..75){
                observer.onNext("anotherValue_$i")
            }
            observer.onCompleted()
        })
        t.start()
        Subscription{
            t.interrupt()
        }
    }.asObservable()
}