Saharath Kleips
ReactiveRedisTemplate
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") }
awaitFirst
A modern programming language that makes developers happier.