kluck
05/09/2019, 8:58 AMIAccessTokenRepository
, which handles the cached version or not.
fun <DTO> IO<DTO>.withToken(accessTokenRepository: IAccessTokenRepository): IO<DTO> = handleErrorWith {
if (it is HttpException && it.code() == 401) {
accessTokenRepository.refreshAccessToken().flatMap { withToken(accessTokenRepository) }
} else {
raiseError(it)
}
}