timeout

fun <T> Observable<T>.timeout(time: Long, unit: TimeUnit, error: Throwable): Observable<T>