throwAfterDuration

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

Content copied to clipboard

fun Completable.throwAfterDuration(timeout: Long, unit: TimeUnit, error: Throwable): Completable

Content copied to clipboard