RXJava 2.0 deeply nested chain failing to execute parts
I have the following RXJava 2.0 code:
private fun wrapApiRequestSingle(apiCall: () -> Single, token: Token) : Single =
Single.defer {
apiCall.invoke()
}.retryWhen { obsError ->
obsError.flatMap { error ->
when (error) {
is TokenExpiredException -> {
userRepository.getLoggedInUser().toFlowable().flatMap { userOptional ->
Publisher {...