retryWhenSample8.kt

internal class ImagesRepositoryImpl(private val source: ImageDataSource) : ImagesRepository {
    override fun getImages(params: Map<String, String>): Single<Result<ImagesResponse>> {
        return source.getImages(params)
            .map { Result.success(it) }
            .onErrorResumeNext { Single.just(Result.failure(it)) }
            .compose(applyRetryPolicy(TIMEOUT) { Single.just(Result.failure(it)) })
    }
}