From 89f4c7e238849e55e67c59d97d1386b39b7f5f4a Mon Sep 17 00:00:00 2001 From: Dylan Date: Fri, 7 Jan 2022 02:04:29 -0500 Subject: [PATCH] Add approximate trimming to reactive stream extensions. See #2227 --- .../data/redis/core/ReactiveStreamOperationsExtensions.kt | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/kotlin/org/springframework/data/redis/core/ReactiveStreamOperationsExtensions.kt b/src/main/kotlin/org/springframework/data/redis/core/ReactiveStreamOperationsExtensions.kt index 04c07bd99..27b18b330 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveStreamOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveStreamOperationsExtensions.kt @@ -263,7 +263,9 @@ inline fun ReactiveStreamOperations.reverseR * Coroutines variant of [ReactiveStreamOperations.trim]. * * @author Mark Paluch + * @author Quantum64@github * @since 2.2 */ -suspend fun ReactiveStreamOperations.trimAndAwait(key: K, count: Long): Long = - trim(key, count).awaitSingle() +@JvmOverloads // Maintain compatibility with versions <= 2.6.0 +suspend fun ReactiveStreamOperations.trimAndAwait(key: K, count: Long, approximateTrimming: Boolean = false): Long = + trim(key, count, approximateTrimming).awaitSingle()