Hoping someone might be able to help identify the ...
# spring
s
Hoping someone might be able to help identify the reason why this code might be breaking. I’m trying to use the
ReactiveRedisTemplate
from the reactive Redis starter.
Copy code
val template = ReactiveStringRedisTemplate(connectionFactory)
template.opsForValue().get("123").subscribe { println("get: $it") } // works! prints: "get: ..."

runBlocking {
  val value = template.opsForValue().get("123").awaitFirst() // fails! connection timeout????
  println("get: $value")
}
I’m not sure if this is a coroutines specific issue but
awaitFirst
works when converting other fluxes.
It looks like upgrading everything from from Spring Boot 2.3 to 2.4 and upgrading from Kotlin 1.3 to 1.4 has magically resolved everything 🤷