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 8bbfc34984..e7a7f582be 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()