KotlinObservable.kt

inline fun <T> createObservable(scheduler: Scheduler = Schedulers.io(), crossinline func: () -> T) : Observable<T>  =
        Observable.create<T> {
            try {
                it.onNext(func())
                it.onCompleted()
            } catch(e: Throwable) {
                it.onError(e)
            }
        }.subscribeOn(scheduler).observeOn(AndroidSchedulers.mainThread())