У меня есть хранилище Redis, содержащее строковые ключи / значения. Я хотел бы получить поток из ключей, который соответствует регулярному выражению неблокирующим способом.
Функция должна возвращать Flux<List<String>>. Используя блок, я могу сделать что-то подобное, но он блокирует, поэтому это не идеальное решение
RedisReactiveCommands<String, String> commands = connection.reactive();
commands.keys("TEST_*")
.map(key -> commands.get(key).block())
.collectList()
.repeat();