Unable to create Observable in Koltin
I am trying to create Observable in kotlin .But its giving error unresolved reference on OnSubscribe method
return Observable.create(object :Observable.OnSubscribe ->{})
I tried this snippet .It also does not work
Observable.create(object : ObservableOn.OnSubscribe {
override fun call(subscriber: Subscriber) {
for(i in 1 .. 5)
subscriber.onNext(i)
subscriber.onCompleted()
}
})
What i am doing wrong...