Hi, in RxKotlin is this function `fun <T> o...

# announcements

[dasralph]

Hi,

in RxKotlin is this function fun <T> observable(body : (s : Subscriber<in T>) -> Unit) : Observable<T> = Observable.create(body). Why is s from type Subscriber<in T>?.

Observable.create wants a OnSubscribe<T> and OnSubscribe extends Action1<Subscriber<? super T>>. So why is s from type Subscriber<in T> and not from type Action1<Subscriber<in T>>?