From 669d3a9c5cc673c33b26a866c508187d72490c61 Mon Sep 17 00:00:00 2001 From: Sebastien Deleuze Date: Mon, 9 Sep 2019 10:45:43 +0200 Subject: [PATCH] DATAREDIS-1033 - Avoid inline reified extensions when unnecessary Original Pull Request: #477 --- .../core/ReactiveGeoOperationsExtensions.kt | 24 ++++----- .../core/ReactiveHashOperationsExtensions.kt | 22 ++++---- ...ReactiveHyperLogLogOperationsExtensions.kt | 8 +-- .../core/ReactiveListOperationsExtensions.kt | 40 +++++++-------- .../core/ReactiveRedisOperationsExtensions.kt | 26 +++++----- .../core/ReactiveSetOperationsExtensions.kt | 28 +++++------ .../ReactiveStreamOperationsExtensions.kt | 28 +++++------ .../core/ReactiveValueOperationsExtensions.kt | 50 +++++++++---------- .../core/ReactiveZSetOperationsExtensions.kt | 38 +++++++------- 9 files changed, 132 insertions(+), 132 deletions(-) diff --git a/src/main/kotlin/org/springframework/data/redis/core/ReactiveGeoOperationsExtensions.kt b/src/main/kotlin/org/springframework/data/redis/core/ReactiveGeoOperationsExtensions.kt index 94e1b1535..25dee9546 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveGeoOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveGeoOperationsExtensions.kt @@ -28,7 +28,7 @@ import org.springframework.data.redis.connection.RedisGeoCommands * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveGeoOperations.addAndAwait(key: K, point: Point, member: M): Long = +suspend fun ReactiveGeoOperations.addAndAwait(key: K, point: Point, member: M): Long = add(key, point, member).awaitSingle() /** @@ -37,7 +37,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.addAndAwait(key: K, location: RedisGeoCommands.GeoLocation): Long = +suspend fun ReactiveGeoOperations.addAndAwait(key: K, location: RedisGeoCommands.GeoLocation): Long = add(key, location).awaitSingle() /** @@ -46,7 +46,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.addAndAwait(key: K, memberCoordinateMap: Map): Long = +suspend fun ReactiveGeoOperations.addAndAwait(key: K, memberCoordinateMap: Map): Long = add(key, memberCoordinateMap).awaitSingle() /** @@ -55,7 +55,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.addAndAwait(key: K, locations: Iterable>): Long = +suspend fun ReactiveGeoOperations.addAndAwait(key: K, locations: Iterable>): Long = add(key, locations).awaitSingle() /** @@ -65,7 +65,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.distanceAndAwait(key: K, member1: M, member2: M): Distance? = +suspend fun ReactiveGeoOperations.distanceAndAwait(key: K, member1: M, member2: M): Distance? = distance(key, member1, member2).awaitFirstOrNull() /** @@ -75,7 +75,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.distanceAndAwait(key: K, member1: M, member2: M, metric: Metric): Distance? = +suspend fun ReactiveGeoOperations.distanceAndAwait(key: K, member1: M, member2: M, metric: Metric): Distance? = distance(key, member1, member2, metric).awaitFirstOrNull() /** @@ -85,7 +85,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.hashAndAwait(key: K, member: M): String? = +suspend fun ReactiveGeoOperations.hashAndAwait(key: K, member: M): String? = hash(key, member).awaitFirstOrNull() /** @@ -94,7 +94,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.hashAndAwait(key: K, vararg member: M): List = +suspend fun ReactiveGeoOperations.hashAndAwait(key: K, vararg member: M): List = hash(key, *member).awaitSingle() /** @@ -103,7 +103,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.positionAndAwait(key: K, member: M): Point? = +suspend fun ReactiveGeoOperations.positionAndAwait(key: K, member: M): Point? = position(key, member).awaitFirstOrNull() /** @@ -112,7 +112,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.positionAndAwait(key: K, vararg members: M): List = +suspend fun ReactiveGeoOperations.positionAndAwait(key: K, vararg members: M): List = position(key, *members).awaitSingle() /** @@ -121,7 +121,7 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.removeAndAwait(key: K, vararg member: M): Long = +suspend fun ReactiveGeoOperations.removeAndAwait(key: K, vararg member: M): Long = remove(key, *member).awaitSingle() /** @@ -130,5 +130,5 @@ suspend inline fun ReactiveGeoOperations ReactiveGeoOperations.deleteAndAwait(key: K): Boolean = +suspend fun ReactiveGeoOperations.deleteAndAwait(key: K): Boolean = delete(key).awaitSingle() diff --git a/src/main/kotlin/org/springframework/data/redis/core/ReactiveHashOperationsExtensions.kt b/src/main/kotlin/org/springframework/data/redis/core/ReactiveHashOperationsExtensions.kt index 08c3cf2ba..b1953bbae 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveHashOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveHashOperationsExtensions.kt @@ -24,7 +24,7 @@ import kotlinx.coroutines.reactive.awaitSingle * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHashOperations.hasKeyAndAwait(key: H, hashKey: HK): Boolean = +suspend fun ReactiveHashOperations.hasKeyAndAwait(key: H, hashKey: HK): Boolean = hasKey(key, hashKey).awaitSingle() /** @@ -34,7 +34,7 @@ suspend inline fun Reactiv * @author Christoph Strobl * @since 2.2 */ -suspend inline fun ReactiveHashOperations.getAndAwait(key: H, hashKey: HK): HV? = +suspend fun ReactiveHashOperations.getAndAwait(key: H, hashKey: HK): HV? = get(key, hashKey).awaitFirstOrNull() /** @@ -43,7 +43,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHashOperations.multiGetAndAwait(key: H, vararg hashKeys: HK): List = +suspend fun ReactiveHashOperations.multiGetAndAwait(key: H, vararg hashKeys: HK): List = multiGet(key, hashKeys.toCollection(ArrayList())).awaitSingle() /** @@ -52,7 +52,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHashOperations.incrementAndAwait(key: H, hashKey: HK, delta: Long): Long = +suspend fun ReactiveHashOperations.incrementAndAwait(key: H, hashKey: HK, delta: Long): Long = increment(key, hashKey, delta).awaitSingle() /** @@ -61,7 +61,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHashOperations.incrementAndAwait(key: H, hashKey: HK, delta: Double): Double = +suspend fun ReactiveHashOperations.incrementAndAwait(key: H, hashKey: HK, delta: Double): Double = increment(key, hashKey, delta).awaitSingle() /** @@ -70,7 +70,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHashOperations.sizeAndAwait(key: H): Long = +suspend fun ReactiveHashOperations.sizeAndAwait(key: H): Long = size(key).awaitSingle() /** @@ -79,7 +79,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHashOperations.putAllAndAwait(key: H, map: Map): Boolean = +suspend fun ReactiveHashOperations.putAllAndAwait(key: H, map: Map): Boolean = putAll(key, map).awaitSingle() /** @@ -88,7 +88,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHashOperations.putAndAwait(key: H, hashKey: HK, hashValue: HV): Boolean = +suspend fun ReactiveHashOperations.putAndAwait(key: H, hashKey: HK, hashValue: HV): Boolean = put(key, hashKey, hashValue).awaitSingle() /** @@ -97,7 +97,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHashOperations.putIfAbsentAndAwait(key: H, hashKey: HK, hashValue: HV): Boolean = +suspend fun ReactiveHashOperations.putIfAbsentAndAwait(key: H, hashKey: HK, hashValue: HV): Boolean = putIfAbsent(key, hashKey, hashValue).awaitSingle() /** @@ -106,7 +106,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHashOperations.removeAndAwait(key: H, vararg hashKeys: Any): Long = +suspend fun ReactiveHashOperations.removeAndAwait(key: H, vararg hashKeys: Any): Long = remove(key, *hashKeys).awaitSingle() /** @@ -115,5 +115,5 @@ suspend inline fun Reactiv * @author Christoph Strobl * @since 2.2 */ -suspend inline fun ReactiveHashOperations.deleteAndAwait(key: H): Boolean = +suspend fun ReactiveHashOperations.deleteAndAwait(key: H): Boolean = delete(key).awaitSingle() diff --git a/src/main/kotlin/org/springframework/data/redis/core/ReactiveHyperLogLogOperationsExtensions.kt b/src/main/kotlin/org/springframework/data/redis/core/ReactiveHyperLogLogOperationsExtensions.kt index d8e752f91..7e6ee4037 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveHyperLogLogOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveHyperLogLogOperationsExtensions.kt @@ -23,7 +23,7 @@ import kotlinx.coroutines.reactive.awaitSingle * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHyperLogLogOperations.addAndAwait(key: K, vararg values: V): Long = +suspend fun ReactiveHyperLogLogOperations.addAndAwait(key: K, vararg values: V): Long = add(key, *values).awaitSingle() /** @@ -32,7 +32,7 @@ suspend inline fun ReactiveHyperLogLogOperati * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHyperLogLogOperations.sizeAndAwait(vararg keys: K): Long = +suspend fun ReactiveHyperLogLogOperations.sizeAndAwait(vararg keys: K): Long = size(*keys).awaitSingle() /** @@ -41,7 +41,7 @@ suspend inline fun ReactiveHyperLogLogOperati * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHyperLogLogOperations.unionAndAwait(destination: K, vararg sourceKeys: K): Boolean = +suspend fun ReactiveHyperLogLogOperations.unionAndAwait(destination: K, vararg sourceKeys: K): Boolean = union(destination, *sourceKeys).awaitSingle() /** @@ -50,5 +50,5 @@ suspend inline fun ReactiveHyperLogLogOperati * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveHyperLogLogOperations.deleteAndAwait(key: K): Boolean = +suspend fun ReactiveHyperLogLogOperations.deleteAndAwait(key: K): Boolean = delete(key).awaitSingle() diff --git a/src/main/kotlin/org/springframework/data/redis/core/ReactiveListOperationsExtensions.kt b/src/main/kotlin/org/springframework/data/redis/core/ReactiveListOperationsExtensions.kt index 43f1d8769..6b770791a 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveListOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveListOperationsExtensions.kt @@ -25,7 +25,7 @@ import java.time.Duration * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveListOperations.trimAndAwait(key: K, start: Long, end: Long): Boolean = +suspend fun ReactiveListOperations.trimAndAwait(key: K, start: Long, end: Long): Boolean = trim(key, start, end).awaitSingle() /** @@ -34,7 +34,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.sizeAndAwait(key: K): Long = +suspend fun ReactiveListOperations.sizeAndAwait(key: K): Long = size(key).awaitSingle() /** @@ -43,7 +43,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.leftPushAndAwait(key: K, value: V): Long = +suspend fun ReactiveListOperations.leftPushAndAwait(key: K, value: V): Long = leftPush(key, value).awaitSingle() /** @@ -52,7 +52,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.leftPushAllAndAwait(key: K, vararg values: V): Long = +suspend fun ReactiveListOperations.leftPushAllAndAwait(key: K, vararg values: V): Long = leftPushAll(key, *values).awaitSingle() /** @@ -61,7 +61,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.leftPushAllAndAwait(key: K, values: Collection): Long = +suspend fun ReactiveListOperations.leftPushAllAndAwait(key: K, values: Collection): Long = leftPushAll(key, values).awaitSingle() /** @@ -70,7 +70,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.leftPushIfPresentAndAwait(key: K, value: V): Long = +suspend fun ReactiveListOperations.leftPushIfPresentAndAwait(key: K, value: V): Long = leftPushIfPresent(key, value).awaitSingle() /** @@ -79,7 +79,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.leftPushAndAwait(key: K, pivot: V, value: V): Long = +suspend fun ReactiveListOperations.leftPushAndAwait(key: K, pivot: V, value: V): Long = leftPush(key, pivot, value).awaitSingle() /** @@ -88,7 +88,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.rightPushAndAwait(key: K, value: V): Long = +suspend fun ReactiveListOperations.rightPushAndAwait(key: K, value: V): Long = rightPush(key, value).awaitSingle() /** @@ -97,7 +97,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.rightPushAllAndAwait(key: K, vararg values: V): Long = +suspend fun ReactiveListOperations.rightPushAllAndAwait(key: K, vararg values: V): Long = rightPushAll(key, *values).awaitSingle() /** @@ -106,7 +106,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.rightPushAllAndAwait(key: K, values: Collection): Long = +suspend fun ReactiveListOperations.rightPushAllAndAwait(key: K, values: Collection): Long = rightPushAll(key, values).awaitSingle() /** @@ -115,7 +115,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.rightPushIfPresentAndAwait(key: K, value: V): Long = +suspend fun ReactiveListOperations.rightPushIfPresentAndAwait(key: K, value: V): Long = rightPushIfPresent(key, value).awaitSingle() /** @@ -124,7 +124,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.rightPushAndAwait(key: K, pivot: V, value: V): Long = +suspend fun ReactiveListOperations.rightPushAndAwait(key: K, pivot: V, value: V): Long = rightPush(key, pivot, value).awaitSingle() /** @@ -133,7 +133,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.setAndAwait(key: K, index: Long, value: V): Boolean = +suspend fun ReactiveListOperations.setAndAwait(key: K, index: Long, value: V): Boolean = set(key, index, value).awaitSingle() /** @@ -142,7 +142,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.removeAndAwait(key: K, count: Long, value: V): Long = +suspend fun ReactiveListOperations.removeAndAwait(key: K, count: Long, value: V): Long = remove(key, count, value).awaitSingle() /** @@ -151,7 +151,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.indexAndAwait(key: K, index: Long): V? = +suspend fun ReactiveListOperations.indexAndAwait(key: K, index: Long): V? = index(key, index).awaitFirstOrNull() /** @@ -160,7 +160,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.leftPopAndAwait(key: K): V? = +suspend fun ReactiveListOperations.leftPopAndAwait(key: K): V? = leftPop(key).awaitFirstOrNull() /** @@ -169,7 +169,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.leftPopAndAwait(key: K, timeout: Duration): V? = +suspend fun ReactiveListOperations.leftPopAndAwait(key: K, timeout: Duration): V? = leftPop(key, timeout).awaitFirstOrNull() /** @@ -178,7 +178,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.rightPopAndAwait(key: K): V? = +suspend fun ReactiveListOperations.rightPopAndAwait(key: K): V? = rightPop(key).awaitFirstOrNull() /** @@ -187,7 +187,7 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.rightPopAndAwait(key: K, timeout: Duration): V? = +suspend fun ReactiveListOperations.rightPopAndAwait(key: K, timeout: Duration): V? = rightPop(key, timeout).awaitFirstOrNull() /** @@ -196,5 +196,5 @@ suspend inline fun ReactiveListOperations ReactiveListOperations.deleteAndAwait(key: K): Boolean = +suspend fun ReactiveListOperations.deleteAndAwait(key: K): Boolean = delete(key).awaitSingle() diff --git a/src/main/kotlin/org/springframework/data/redis/core/ReactiveRedisOperationsExtensions.kt b/src/main/kotlin/org/springframework/data/redis/core/ReactiveRedisOperationsExtensions.kt index 056c5a2d1..5618e2f4f 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveRedisOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveRedisOperationsExtensions.kt @@ -27,7 +27,7 @@ import java.time.Instant * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveRedisOperations.sendAndAwait(destination: String, message: V): Long = +suspend fun ReactiveRedisOperations.sendAndAwait(destination: String, message: V): Long = convertAndSend(destination, message).awaitSingle() /** @@ -36,7 +36,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.hasKeyAndAwait(key: K): Boolean = +suspend fun ReactiveRedisOperations.hasKeyAndAwait(key: K): Boolean = hasKey(key).awaitSingle() /** @@ -45,7 +45,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.typeAndAwait(key: K): DataType = +suspend fun ReactiveRedisOperations.typeAndAwait(key: K): DataType = type(key).awaitSingle() /** @@ -54,7 +54,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.randomKeyAndAwait(): K? = +suspend fun ReactiveRedisOperations.randomKeyAndAwait(): K? = randomKey().awaitFirstOrNull() /** @@ -63,7 +63,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.renameAndAwait(oldKey: K, newKey: K): Boolean = +suspend fun ReactiveRedisOperations.renameAndAwait(oldKey: K, newKey: K): Boolean = rename(oldKey, newKey).awaitSingle() /** @@ -72,7 +72,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.renameIfAbsentAndAwait(oldKey: K, newKey: K): Boolean = +suspend fun ReactiveRedisOperations.renameIfAbsentAndAwait(oldKey: K, newKey: K): Boolean = renameIfAbsent(oldKey, newKey).awaitSingle() /** @@ -81,7 +81,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.deleteAndAwait(vararg key: K): Long = +suspend fun ReactiveRedisOperations.deleteAndAwait(vararg key: K): Long = delete(*key).awaitSingle() /** @@ -90,7 +90,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.unlinkAndAwait(vararg key: K): Long = +suspend fun ReactiveRedisOperations.unlinkAndAwait(vararg key: K): Long = unlink(*key).awaitSingle() /** @@ -99,7 +99,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.expireAndAwait(key: K, timeout: Duration): Boolean = +suspend fun ReactiveRedisOperations.expireAndAwait(key: K, timeout: Duration): Boolean = expire(key, timeout).awaitSingle() /** @@ -108,7 +108,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.expireAtAndAwait(key: K, expireAt: Instant): Boolean = expireAt(key, expireAt).awaitSingle() +suspend fun ReactiveRedisOperations.expireAtAndAwait(key: K, expireAt: Instant): Boolean = expireAt(key, expireAt).awaitSingle() /** @@ -117,7 +117,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.persistAndAwait(key: K): Boolean = +suspend fun ReactiveRedisOperations.persistAndAwait(key: K): Boolean = persist(key).awaitSingle() /** @@ -126,7 +126,7 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.moveAndAwait(key: K, dbIndex: Int): Boolean = move(key, dbIndex).awaitSingle() +suspend fun ReactiveRedisOperations.moveAndAwait(key: K, dbIndex: Int): Boolean = move(key, dbIndex).awaitSingle() /** * Coroutines variant of [ReactiveRedisOperations.getExpire]. @@ -134,4 +134,4 @@ suspend inline fun ReactiveRedisOperations ReactiveRedisOperations.getExpireAndAwait(key: K): Duration? = getExpire(key).awaitFirstOrNull() +suspend fun ReactiveRedisOperations.getExpireAndAwait(key: K): Duration? = getExpire(key).awaitFirstOrNull() diff --git a/src/main/kotlin/org/springframework/data/redis/core/ReactiveSetOperationsExtensions.kt b/src/main/kotlin/org/springframework/data/redis/core/ReactiveSetOperationsExtensions.kt index 83f154952..5dcdd9dcd 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveSetOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveSetOperationsExtensions.kt @@ -24,7 +24,7 @@ import kotlinx.coroutines.reactive.awaitSingle * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveSetOperations.addAndAwait(key: K, vararg values: V): Long = +suspend fun ReactiveSetOperations.addAndAwait(key: K, vararg values: V): Long = add(key, *values).awaitSingle() /** @@ -33,7 +33,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.removeAndAwait(key: K, vararg values: V): Long = +suspend fun ReactiveSetOperations.removeAndAwait(key: K, vararg values: V): Long = remove(key, *values).awaitSingle() /** @@ -42,7 +42,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.popAndAwait(key: K): V? = +suspend fun ReactiveSetOperations.popAndAwait(key: K): V? = pop(key).awaitFirstOrNull() /** @@ -51,7 +51,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.moveAndAwait(sourceKey: K, value: V, destKey: K): Boolean = +suspend fun ReactiveSetOperations.moveAndAwait(sourceKey: K, value: V, destKey: K): Boolean = move(sourceKey, value, destKey).awaitSingle() /** @@ -60,7 +60,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.sizeAndAwait(key: K): Long = +suspend fun ReactiveSetOperations.sizeAndAwait(key: K): Long = size(key).awaitSingle() /** @@ -69,7 +69,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.isMemberAndAwait(key: K, value: V): Boolean = +suspend fun ReactiveSetOperations.isMemberAndAwait(key: K, value: V): Boolean = isMember(key, value).awaitSingle() /** @@ -78,7 +78,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.intersectAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = +suspend fun ReactiveSetOperations.intersectAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = intersectAndStore(key, otherKey, destKey).awaitSingle() /** @@ -87,7 +87,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.intersectAndStoreAndAwait(keys: Collection, destKey: K): Long = +suspend fun ReactiveSetOperations.intersectAndStoreAndAwait(keys: Collection, destKey: K): Long = intersectAndStore(keys, destKey).awaitSingle() /** @@ -96,7 +96,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.unionAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = +suspend fun ReactiveSetOperations.unionAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = unionAndStore(key, otherKey, destKey).awaitSingle() /** @@ -105,7 +105,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.unionAndStoreAndAwait(keys: Collection, destKey: K): Long = +suspend fun ReactiveSetOperations.unionAndStoreAndAwait(keys: Collection, destKey: K): Long = unionAndStore(keys, destKey).awaitSingle() /** @@ -114,7 +114,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.differenceAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = +suspend fun ReactiveSetOperations.differenceAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = differenceAndStore(key, otherKey, destKey).awaitSingle() /** @@ -123,7 +123,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.differenceAndStoreAndAwait(keys: Collection, destKey: K): Long = +suspend fun ReactiveSetOperations.differenceAndStoreAndAwait(keys: Collection, destKey: K): Long = differenceAndStore(keys, destKey).awaitSingle() /** @@ -132,7 +132,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.randomMemberAndAwait(key: K): V? = +suspend fun ReactiveSetOperations.randomMemberAndAwait(key: K): V? = randomMember(key).awaitFirstOrNull() /** @@ -141,7 +141,7 @@ suspend inline fun ReactiveSetOperations ReactiveSetOperations.deleteAndAwait(key: K): Boolean = +suspend fun ReactiveSetOperations.deleteAndAwait(key: K): Boolean = delete(key).awaitSingle() 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 20cc45ded..6e7dbf89a 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveStreamOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveStreamOperationsExtensions.kt @@ -24,7 +24,7 @@ import org.springframework.data.redis.connection.stream.* * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.acknowledgeAndAwait(key: K, group: String, vararg recordIds: String): Long = +suspend fun ReactiveStreamOperations.acknowledgeAndAwait(key: K, group: String, vararg recordIds: String): Long = acknowledge(key, group, *recordIds).awaitSingle() /** @@ -33,7 +33,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.acknowledgeAndAwait(key: K, group: String, vararg recordIds: RecordId): Long = +suspend fun ReactiveStreamOperations.acknowledgeAndAwait(key: K, group: String, vararg recordIds: RecordId): Long = acknowledge(key, group, *recordIds).awaitSingle() /** @@ -42,7 +42,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.acknowledgeAndAwait(group: String, record: Record): Long = +suspend fun ReactiveStreamOperations.acknowledgeAndAwait(group: String, record: Record): Long = acknowledge(group, record).awaitSingle() /** @@ -51,7 +51,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.addAndAwait(record: MapRecord): RecordId = +suspend fun ReactiveStreamOperations.addAndAwait(record: MapRecord): RecordId = add(record).awaitSingle() /** @@ -60,7 +60,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.addAndAwait(record: Record): RecordId = +suspend fun ReactiveStreamOperations.addAndAwait(record: Record): RecordId = add(record).awaitSingle() /** @@ -69,7 +69,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.deleteAndAwait(key: K, vararg recordIds: String): Long = +suspend fun ReactiveStreamOperations.deleteAndAwait(key: K, vararg recordIds: String): Long = delete(key, *recordIds).awaitSingle() /** @@ -78,7 +78,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.deleteAndAwait(record: Record): Long = +suspend fun ReactiveStreamOperations.deleteAndAwait(record: Record): Long = delete(record).awaitSingle() /** @@ -87,7 +87,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.deleteAndAwait(key: K, vararg recordIds: RecordId): Long = +suspend fun ReactiveStreamOperations.deleteAndAwait(key: K, vararg recordIds: RecordId): Long = delete(key, *recordIds).awaitSingle() /** @@ -96,7 +96,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.createGroupAndAwait(key: K, group: String): String = +suspend fun ReactiveStreamOperations.createGroupAndAwait(key: K, group: String): String = createGroup(key, group).awaitSingle() /** @@ -105,7 +105,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.createGroupAndAwait(key: K, readOffset: ReadOffset, group: String): String = +suspend fun ReactiveStreamOperations.createGroupAndAwait(key: K, readOffset: ReadOffset, group: String): String = createGroup(key, readOffset, group).awaitSingle() /** @@ -114,7 +114,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.deleteConsumerAndAwait(key: K, consumer: Consumer): String = +suspend fun ReactiveStreamOperations.deleteConsumerAndAwait(key: K, consumer: Consumer): String = deleteConsumer(key, consumer).awaitSingle() /** @@ -123,7 +123,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.destroyGroupAndAwait(key: K, group: String): String = +suspend fun ReactiveStreamOperations.destroyGroupAndAwait(key: K, group: String): String = destroyGroup(key, group).awaitSingle() /** @@ -132,7 +132,7 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.sizeAndAwait(key: K): Long = +suspend fun ReactiveStreamOperations.sizeAndAwait(key: K): Long = size(key).awaitSingle() /** @@ -141,5 +141,5 @@ suspend inline fun Reactiv * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveStreamOperations.trimAndAwait(key: K, count: Long): Long = +suspend fun ReactiveStreamOperations.trimAndAwait(key: K, count: Long): Long = trim(key, count).awaitSingle() diff --git a/src/main/kotlin/org/springframework/data/redis/core/ReactiveValueOperationsExtensions.kt b/src/main/kotlin/org/springframework/data/redis/core/ReactiveValueOperationsExtensions.kt index 51b28f197..fe2325b67 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveValueOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveValueOperationsExtensions.kt @@ -26,7 +26,7 @@ import java.time.Duration * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveValueOperations.setAndAwait(key: K, value: V): Boolean = +suspend fun ReactiveValueOperations.setAndAwait(key: K, value: V): Boolean = set(key, value).awaitSingle() /** @@ -35,7 +35,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.setAndAwait(key: K, value: V, timeout: Duration): Boolean = +suspend fun ReactiveValueOperations.setAndAwait(key: K, value: V, timeout: Duration): Boolean = set(key, value, timeout).awaitSingle() /** @@ -44,7 +44,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.setIfAbsentAndAwait(key: K, value: V): Boolean = +suspend fun ReactiveValueOperations.setIfAbsentAndAwait(key: K, value: V): Boolean = setIfAbsent(key, value).awaitSingle() /** @@ -53,7 +53,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.setIfAbsentAndAwait(key: K, value: V, timeout: Duration): Boolean = +suspend fun ReactiveValueOperations.setIfAbsentAndAwait(key: K, value: V, timeout: Duration): Boolean = setIfAbsent(key, value, timeout).awaitSingle() /** @@ -62,7 +62,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.setIfPresentAndAwait(key: K, value: V): Boolean = +suspend fun ReactiveValueOperations.setIfPresentAndAwait(key: K, value: V): Boolean = setIfPresent(key, value).awaitSingle() /** @@ -71,7 +71,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.setIfPresentAndAwait(key: K, value: V, timeout: Duration): Boolean = +suspend fun ReactiveValueOperations.setIfPresentAndAwait(key: K, value: V, timeout: Duration): Boolean = setIfPresent(key, value, timeout).awaitSingle() /** @@ -80,7 +80,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.multiSetAndAwait(map: Map): Boolean = +suspend fun ReactiveValueOperations.multiSetAndAwait(map: Map): Boolean = multiSet(map).awaitSingle() /** @@ -89,7 +89,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.multiSetIfAbsentAndAwait(map: Map): Boolean = +suspend fun ReactiveValueOperations.multiSetIfAbsentAndAwait(map: Map): Boolean = multiSetIfAbsent(map).awaitSingle() /** @@ -98,7 +98,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.getAndAwait(key: K): V? = +suspend fun ReactiveValueOperations.getAndAwait(key: K): V? = get(key).awaitFirstOrNull() /** @@ -108,7 +108,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.getAndSetAndAwait(key: K, value: V): V? = +suspend fun ReactiveValueOperations.getAndSetAndAwait(key: K, value: V): V? = getAndSet(key, value).awaitFirstOrNull() /** @@ -117,7 +117,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.multiGetAndAwait(vararg keys: K): List = +suspend fun ReactiveValueOperations.multiGetAndAwait(vararg keys: K): List = multiGet(keys.toCollection(ArrayList())).awaitSingle() /** @@ -126,7 +126,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.multiGetAndAwait(keys: Collection): List = +suspend fun ReactiveValueOperations.multiGetAndAwait(keys: Collection): List = multiGet(keys).awaitSingle() /** @@ -135,7 +135,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.incrementAndAwait(key: K): Long = +suspend fun ReactiveValueOperations.incrementAndAwait(key: K): Long = increment(key).awaitSingle() /** @@ -144,7 +144,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.incrementAndAwait(key: K, delta: Long): Long = +suspend fun ReactiveValueOperations.incrementAndAwait(key: K, delta: Long): Long = increment(key, delta).awaitSingle() /** @@ -153,7 +153,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.incrementAndAwait(key: K, delta: Double): Double = +suspend fun ReactiveValueOperations.incrementAndAwait(key: K, delta: Double): Double = increment(key, delta).awaitSingle() /** @@ -162,7 +162,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.decrementAndAwait(key: K): Long = +suspend fun ReactiveValueOperations.decrementAndAwait(key: K): Long = decrement(key).awaitSingle() /** @@ -171,7 +171,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.decrementAndAwait(key: K, delta: Long): Long = +suspend fun ReactiveValueOperations.decrementAndAwait(key: K, delta: Long): Long = decrement(key, delta).awaitSingle() /** @@ -180,7 +180,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.appendAndAwait(key: K, value: String): Long = +suspend fun ReactiveValueOperations.appendAndAwait(key: K, value: String): Long = append(key, value).awaitSingle() /** @@ -189,7 +189,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.getAndAwait(key: K, start: Long, end: Long): String? = +suspend fun ReactiveValueOperations.getAndAwait(key: K, start: Long, end: Long): String? = get(key, start, end).awaitFirstOrNull() /** @@ -198,7 +198,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.setAndAwait(key: K, value: V, offset: Long): Long = +suspend fun ReactiveValueOperations.setAndAwait(key: K, value: V, offset: Long): Long = set(key, value, offset).awaitSingle() /** @@ -208,7 +208,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.sizeAndAwait(key: K): Long = +suspend fun ReactiveValueOperations.sizeAndAwait(key: K): Long = size(key).awaitSingle() /** @@ -217,7 +217,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.setBitAndAwait(key: K, offset: Long, value: Boolean): Boolean = +suspend fun ReactiveValueOperations.setBitAndAwait(key: K, offset: Long, value: Boolean): Boolean = setBit(key, offset, value).awaitSingle() /** @@ -226,7 +226,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.getBitAndAwait(key: K, offset: Long): Boolean = +suspend fun ReactiveValueOperations.getBitAndAwait(key: K, offset: Long): Boolean = getBit(key, offset).awaitSingle() /** @@ -235,7 +235,7 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.bitFieldAndAwait(key: K, commands: BitFieldSubCommands): List = +suspend fun ReactiveValueOperations.bitFieldAndAwait(key: K, commands: BitFieldSubCommands): List = bitField(key, commands).awaitSingle() /** @@ -244,5 +244,5 @@ suspend inline fun ReactiveValueOperations ReactiveValueOperations.deleteAndAwait(key: K): Boolean = +suspend fun ReactiveValueOperations.deleteAndAwait(key: K): Boolean = delete(key).awaitSingle() diff --git a/src/main/kotlin/org/springframework/data/redis/core/ReactiveZSetOperationsExtensions.kt b/src/main/kotlin/org/springframework/data/redis/core/ReactiveZSetOperationsExtensions.kt index 2e22c6801..942bde7e9 100644 --- a/src/main/kotlin/org/springframework/data/redis/core/ReactiveZSetOperationsExtensions.kt +++ b/src/main/kotlin/org/springframework/data/redis/core/ReactiveZSetOperationsExtensions.kt @@ -26,7 +26,7 @@ import org.springframework.data.redis.connection.RedisZSetCommands * @author Mark Paluch * @since 2.2 */ -suspend inline fun ReactiveZSetOperations.addAndAwait(key: K, value: V, score: Double): Boolean = +suspend fun ReactiveZSetOperations.addAndAwait(key: K, value: V, score: Double): Boolean = add(key, value, score).awaitSingle() /** @@ -35,7 +35,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.addAllAndAwait(key: K, values: Collection>): Long = +suspend fun ReactiveZSetOperations.addAllAndAwait(key: K, values: Collection>): Long = addAll(key, values).awaitSingle() /** @@ -44,7 +44,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.removeAndAwait(key: K, vararg values: Any): Long = +suspend fun ReactiveZSetOperations.removeAndAwait(key: K, vararg values: Any): Long = remove(key, *values).awaitSingle() /** @@ -53,7 +53,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.incrementScoreAndAwait(key: K, value: V, score: Double): Double = +suspend fun ReactiveZSetOperations.incrementScoreAndAwait(key: K, value: V, score: Double): Double = incrementScore(key, value, score).awaitSingle() /** @@ -62,7 +62,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.rankAndAwait(key: K, value: V): Long? = +suspend fun ReactiveZSetOperations.rankAndAwait(key: K, value: V): Long? = rank(key, value).awaitFirstOrNull() /** @@ -71,7 +71,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.reverseRankAndAwait(key: K, value: V): Long? = +suspend fun ReactiveZSetOperations.reverseRankAndAwait(key: K, value: V): Long? = reverseRank(key, value).awaitFirstOrNull() /** @@ -80,7 +80,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.countAndAwait(key: K, range: Range): Long = +suspend fun ReactiveZSetOperations.countAndAwait(key: K, range: Range): Long = count(key, range).awaitSingle() /** @@ -89,7 +89,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.scoreAndAwait(key: K, value: V): Double? = +suspend fun ReactiveZSetOperations.scoreAndAwait(key: K, value: V): Double? = score(key, value).awaitFirstOrNull() /** @@ -98,7 +98,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.removeRangeAndAwait(key: K, range: Range): Long = +suspend fun ReactiveZSetOperations.removeRangeAndAwait(key: K, range: Range): Long = removeRange(key, range).awaitSingle() /** @@ -107,7 +107,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.removeRangeByScoreAndAwait(key: K, range: Range): Long = +suspend fun ReactiveZSetOperations.removeRangeByScoreAndAwait(key: K, range: Range): Long = removeRangeByScore(key, range).awaitSingle() /** @@ -116,7 +116,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.unionAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = +suspend fun ReactiveZSetOperations.unionAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = unionAndStore(key, otherKey, destKey).awaitSingle() /** @@ -125,7 +125,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.unionAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K): Long = +suspend fun ReactiveZSetOperations.unionAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K): Long = unionAndStore(key, otherKeys, destKey).awaitSingle() /** @@ -134,7 +134,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.unionAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K, aggregate: RedisZSetCommands.Aggregate): Long = +suspend fun ReactiveZSetOperations.unionAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K, aggregate: RedisZSetCommands.Aggregate): Long = unionAndStore(key, otherKeys, destKey, aggregate).awaitSingle() /** @@ -143,7 +143,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.unionAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K, aggregate: RedisZSetCommands.Aggregate, weights: RedisZSetCommands.Weights): Long = +suspend fun ReactiveZSetOperations.unionAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K, aggregate: RedisZSetCommands.Aggregate, weights: RedisZSetCommands.Weights): Long = unionAndStore(key, otherKeys, destKey, aggregate, weights).awaitSingle() /** @@ -152,7 +152,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.intersectAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = +suspend fun ReactiveZSetOperations.intersectAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long = intersectAndStore(key, otherKey, destKey).awaitSingle() /** @@ -161,7 +161,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.intersectAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K): Long = +suspend fun ReactiveZSetOperations.intersectAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K): Long = intersectAndStore(key, otherKeys, destKey).awaitSingle() /** @@ -170,7 +170,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.intersectAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K, aggregate: RedisZSetCommands.Aggregate): Long = +suspend fun ReactiveZSetOperations.intersectAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K, aggregate: RedisZSetCommands.Aggregate): Long = intersectAndStore(key, otherKeys, destKey, aggregate).awaitSingle() /** @@ -179,7 +179,7 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.intersectAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K, aggregate: RedisZSetCommands.Aggregate, weights: RedisZSetCommands.Weights): Long = +suspend fun ReactiveZSetOperations.intersectAndStoreAndAwait(key: K, otherKeys: Collection, destKey: K, aggregate: RedisZSetCommands.Aggregate, weights: RedisZSetCommands.Weights): Long = intersectAndStore(key, otherKeys, destKey, aggregate, weights).awaitSingle() /** @@ -188,5 +188,5 @@ suspend inline fun ReactiveZSetOperations ReactiveZSetOperations.deleteAndAwait(key: K): Boolean = +suspend fun ReactiveZSetOperations.deleteAndAwait(key: K): Boolean = delete(key).awaitSingle()