ReactiveRedisTemplate удалить не удалить все ключи с издателем

Question

У меня проблема с удалением ключей из Redis реактивным способом - удален только один ключ.Но запрос поиска возвращает несколько результатов.

redisTemplate.delete(redisTemplate.keys(PREFIX + STAR_PATTERN))
                .subscribe(count -> LOGGER.info("Removed {}", count));

этот код удаляет только один ключ (последний);Но когда я изменяю этот код на:

redisTemplate.keys(PREFIX + STAR_PATTERN)
                .flatMap(redisTemplate::delete)
                .subscribe(key -> LOGGER.info("Removed from cache {}", key))

работает нормально.

Почему первый код не удаляет все ключи?

Answer 1

Это похоже на ошибку для меня.ReactiveRedisTemplate.delete(Publisher) считает, что удаляется только первый возвращенный ключ, а не последующие ключи.

Я подал DATAREDIS-913 для отслеживания проблемы.