Saharath Kleips
12/15/2020, 6:01 PMReactiveRedisTemplate
from the reactive Redis starter.
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.Saharath Kleips
12/15/2020, 8:11 PM