fun <T, R> Observable<T>.lift(operator: (Subscriber<in R>) -> Subscriber<T>): Observable<R> = lift { t1 -> operator(t1!!) }