runSafeOnMain
fun <T : Any> Observable<T>.runSafeOnMain(subscribeOn: Scheduler = newThreadScheduler): Observable<T>
observe on main thread subscribe on new thread unsubsidised on error and on complete and removes the need to handle it afterwards