Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATAREDIS-1033 - Avoid inline reified extensions when unnecessary

Browse Source 
Original Pull Request: #477
This commit is contained in:
Sebastien Deleuze
2019-09-09 10:45:43 +02:00
committed by Christoph Strobl
parent 6db2a06428
commit 669d3a9c5c
9 changed files with 132 additions and 132 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/kotlin/org/springframework/data/redis/core/ReactiveGeoOperationsExtensions.kt
View File

@@ -28,7 +28,7 @@ import org.springframework.data.redis.connection.RedisGeoCommands
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.addAndAwait(key: K, point: Point, member: M): Long =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.addAndAwait(key: K, point: Point, member: M): Long =
add(key, point, member).awaitSingle()
/**
@@ -37,7 +37,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.addAndAwait(key: K, location: RedisGeoCommands.GeoLocation<M>): Long =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.addAndAwait(key: K, location: RedisGeoCommands.GeoLocation<M>): Long =
add(key, location).awaitSingle()
/**
@@ -46,7 +46,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.addAndAwait(key: K, memberCoordinateMap: Map<M, Point>): Long =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.addAndAwait(key: K, memberCoordinateMap: Map<M, Point>): Long =
add(key, memberCoordinateMap).awaitSingle()
/**
@@ -55,7 +55,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.addAndAwait(key: K, locations: Iterable<RedisGeoCommands.GeoLocation<M>>): Long =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.addAndAwait(key: K, locations: Iterable<RedisGeoCommands.GeoLocation<M>>): Long =
add(key, locations).awaitSingle()
/**
@@ -65,7 +65,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Christoph Strobl
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.distanceAndAwait(key: K, member1: M, member2: M): Distance? =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.distanceAndAwait(key: K, member1: M, member2: M): Distance? =
distance(key, member1, member2).awaitFirstOrNull()
/**
@@ -75,7 +75,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Christoph Strobl
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.distanceAndAwait(key: K, member1: M, member2: M, metric: Metric): Distance? =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.distanceAndAwait(key: K, member1: M, member2: M, metric: Metric): Distance? =
distance(key, member1, member2, metric).awaitFirstOrNull()
/**
@@ -85,7 +85,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Christoph Strobl
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.hashAndAwait(key: K, member: M): String? =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.hashAndAwait(key: K, member: M): String? =
hash(key, member).awaitFirstOrNull()
/**
@@ -94,7 +94,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.hashAndAwait(key: K, vararg member: M): List<String> =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.hashAndAwait(key: K, vararg member: M): List<String> =
hash(key, *member).awaitSingle()
/**
@@ -103,7 +103,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.positionAndAwait(key: K, member: M): Point? =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.positionAndAwait(key: K, member: M): Point? =
position(key, member).awaitFirstOrNull()
/**
@@ -112,7 +112,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.positionAndAwait(key: K, vararg members: M): List<Point> =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.positionAndAwait(key: K, vararg members: M): List<Point> =
position(key, *members).awaitSingle()
/**
@@ -121,7 +121,7 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.removeAndAwait(key: K, vararg member: M): Long =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.removeAndAwait(key: K, vararg member: M): Long =
remove(key, *member).awaitSingle()
/**
@@ -130,5 +130,5 @@ suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified M : Any> ReactiveGeoOperations<K, M>.deleteAndAwait(key: K): Boolean =
suspend fun <K : Any, M : Any> ReactiveGeoOperations<K, M>.deleteAndAwait(key: K): Boolean =
delete(key).awaitSingle()

22
src/main/kotlin/org/springframework/data/redis/core/ReactiveHashOperationsExtensions.kt
View File

@@ -24,7 +24,7 @@ import kotlinx.coroutines.reactive.awaitSingle
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.hasKeyAndAwait(key: H, hashKey: HK): Boolean =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.hasKeyAndAwait(key: H, hashKey: HK): Boolean =
hasKey(key, hashKey).awaitSingle()
/**
@@ -34,7 +34,7 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Christoph Strobl
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.getAndAwait(key: H, hashKey: HK): HV? =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.getAndAwait(key: H, hashKey: HK): HV? =
get(key, hashKey).awaitFirstOrNull()
/**
@@ -43,7 +43,7 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.multiGetAndAwait(key: H, vararg hashKeys: HK): List<HV?> =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.multiGetAndAwait(key: H, vararg hashKeys: HK): List<HV?> =
multiGet(key, hashKeys.toCollection(ArrayList())).awaitSingle()
/**
@@ -52,7 +52,7 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.incrementAndAwait(key: H, hashKey: HK, delta: Long): Long =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.incrementAndAwait(key: H, hashKey: HK, delta: Long): Long =
increment(key, hashKey, delta).awaitSingle()
/**
@@ -61,7 +61,7 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.incrementAndAwait(key: H, hashKey: HK, delta: Double): Double =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.incrementAndAwait(key: H, hashKey: HK, delta: Double): Double =
increment(key, hashKey, delta).awaitSingle()
/**
@@ -70,7 +70,7 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.sizeAndAwait(key: H): Long =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.sizeAndAwait(key: H): Long =
size(key).awaitSingle()
/**
@@ -79,7 +79,7 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.putAllAndAwait(key: H, map: Map<HK, HV>): Boolean =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.putAllAndAwait(key: H, map: Map<HK, HV>): Boolean =
putAll(key, map).awaitSingle()
/**
@@ -88,7 +88,7 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.putAndAwait(key: H, hashKey: HK, hashValue: HV): Boolean =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.putAndAwait(key: H, hashKey: HK, hashValue: HV): Boolean =
put(key, hashKey, hashValue).awaitSingle()
/**
@@ -97,7 +97,7 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.putIfAbsentAndAwait(key: H, hashKey: HK, hashValue: HV): Boolean =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.putIfAbsentAndAwait(key: H, hashKey: HK, hashValue: HV): Boolean =
putIfAbsent(key, hashKey, hashValue).awaitSingle()
/**
@@ -106,7 +106,7 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.removeAndAwait(key: H, vararg hashKeys: Any): Long =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.removeAndAwait(key: H, vararg hashKeys: Any): Long =
remove(key, *hashKeys).awaitSingle()
/**
@@ -115,5 +115,5 @@ suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Christoph Strobl
* @since 2.2
*/
suspend inline fun <reified H : Any, reified HK : Any, reified HV : Any> ReactiveHashOperations<H, HK, HV>.deleteAndAwait(key: H): Boolean =
suspend fun <H : Any, HK : Any, HV : Any> ReactiveHashOperations<H, HK, HV>.deleteAndAwait(key: H): Boolean =
delete(key).awaitSingle()

8
src/main/kotlin/org/springframework/data/redis/core/ReactiveHyperLogLogOperationsExtensions.kt
View File

@@ -23,7 +23,7 @@ import kotlinx.coroutines.reactive.awaitSingle
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveHyperLogLogOperations<K, V>.addAndAwait(key: K, vararg values: V): Long =
suspend fun <K : Any, V : Any> ReactiveHyperLogLogOperations<K, V>.addAndAwait(key: K, vararg values: V): Long =
add(key, *values).awaitSingle()
/**
@@ -32,7 +32,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveHyperLogLogOperati
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveHyperLogLogOperations<K, V>.sizeAndAwait(vararg keys: K): Long =
suspend fun <K : Any, V : Any> ReactiveHyperLogLogOperations<K, V>.sizeAndAwait(vararg keys: K): Long =
size(*keys).awaitSingle()
/**
@@ -41,7 +41,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveHyperLogLogOperati
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveHyperLogLogOperations<K, V>.unionAndAwait(destination: K, vararg sourceKeys: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveHyperLogLogOperations<K, V>.unionAndAwait(destination: K, vararg sourceKeys: K): Boolean =
union(destination, *sourceKeys).awaitSingle()
/**
@@ -50,5 +50,5 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveHyperLogLogOperati
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveHyperLogLogOperations<K, V>.deleteAndAwait(key: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveHyperLogLogOperations<K, V>.deleteAndAwait(key: K): Boolean =
delete(key).awaitSingle()

40
src/main/kotlin/org/springframework/data/redis/core/ReactiveListOperationsExtensions.kt
View File

@@ -25,7 +25,7 @@ import java.time.Duration
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.trimAndAwait(key: K, start: Long, end: Long): Boolean =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.trimAndAwait(key: K, start: Long, end: Long): Boolean =
trim(key, start, end).awaitSingle()
/**
@@ -34,7 +34,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.sizeAndAwait(key: K): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.sizeAndAwait(key: K): Long =
size(key).awaitSingle()
/**
@@ -43,7 +43,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.leftPushAndAwait(key: K, value: V): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.leftPushAndAwait(key: K, value: V): Long =
leftPush(key, value).awaitSingle()
/**
@@ -52,7 +52,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.leftPushAllAndAwait(key: K, vararg values: V): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.leftPushAllAndAwait(key: K, vararg values: V): Long =
leftPushAll(key, *values).awaitSingle()
/**
@@ -61,7 +61,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.leftPushAllAndAwait(key: K, values: Collection<V>): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.leftPushAllAndAwait(key: K, values: Collection<V>): Long =
leftPushAll(key, values).awaitSingle()
/**
@@ -70,7 +70,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.leftPushIfPresentAndAwait(key: K, value: V): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.leftPushIfPresentAndAwait(key: K, value: V): Long =
leftPushIfPresent(key, value).awaitSingle()
/**
@@ -79,7 +79,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.leftPushAndAwait(key: K, pivot: V, value: V): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.leftPushAndAwait(key: K, pivot: V, value: V): Long =
leftPush(key, pivot, value).awaitSingle()
/**
@@ -88,7 +88,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.rightPushAndAwait(key: K, value: V): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.rightPushAndAwait(key: K, value: V): Long =
rightPush(key, value).awaitSingle()
/**
@@ -97,7 +97,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.rightPushAllAndAwait(key: K, vararg values: V): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.rightPushAllAndAwait(key: K, vararg values: V): Long =
rightPushAll(key, *values).awaitSingle()
/**
@@ -106,7 +106,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.rightPushAllAndAwait(key: K, values: Collection<V>): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.rightPushAllAndAwait(key: K, values: Collection<V>): Long =
rightPushAll(key, values).awaitSingle()
/**
@@ -115,7 +115,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.rightPushIfPresentAndAwait(key: K, value: V): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.rightPushIfPresentAndAwait(key: K, value: V): Long =
rightPushIfPresent(key, value).awaitSingle()
/**
@@ -124,7 +124,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.rightPushAndAwait(key: K, pivot: V, value: V): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.rightPushAndAwait(key: K, pivot: V, value: V): Long =
rightPush(key, pivot, value).awaitSingle()
/**
@@ -133,7 +133,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.setAndAwait(key: K, index: Long, value: V): Boolean =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.setAndAwait(key: K, index: Long, value: V): Boolean =
set(key, index, value).awaitSingle()
/**
@@ -142,7 +142,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.removeAndAwait(key: K, count: Long, value: V): Long =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.removeAndAwait(key: K, count: Long, value: V): Long =
remove(key, count, value).awaitSingle()
/**
@@ -151,7 +151,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.indexAndAwait(key: K, index: Long): V? =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.indexAndAwait(key: K, index: Long): V? =
index(key, index).awaitFirstOrNull()
/**
@@ -160,7 +160,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.leftPopAndAwait(key: K): V? =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.leftPopAndAwait(key: K): V? =
leftPop(key).awaitFirstOrNull()
/**
@@ -169,7 +169,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.leftPopAndAwait(key: K, timeout: Duration): V? =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.leftPopAndAwait(key: K, timeout: Duration): V? =
leftPop(key, timeout).awaitFirstOrNull()
/**
@@ -178,7 +178,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.rightPopAndAwait(key: K): V? =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.rightPopAndAwait(key: K): V? =
rightPop(key).awaitFirstOrNull()
/**
@@ -187,7 +187,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.rightPopAndAwait(key: K, timeout: Duration): V? =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.rightPopAndAwait(key: K, timeout: Duration): V? =
rightPop(key, timeout).awaitFirstOrNull()
/**
@@ -196,5 +196,5 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveListOperations<K, V>.deleteAndAwait(key: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveListOperations<K, V>.deleteAndAwait(key: K): Boolean =
delete(key).awaitSingle()

26
src/main/kotlin/org/springframework/data/redis/core/ReactiveRedisOperationsExtensions.kt
View File

@@ -27,7 +27,7 @@ import java.time.Instant
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.sendAndAwait(destination: String, message: V): Long =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.sendAndAwait(destination: String, message: V): Long =
convertAndSend(destination, message).awaitSingle()
/**
@@ -36,7 +36,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.hasKeyAndAwait(key: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.hasKeyAndAwait(key: K): Boolean =
hasKey(key).awaitSingle()
/**
@@ -45,7 +45,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.typeAndAwait(key: K): DataType =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.typeAndAwait(key: K): DataType =
type(key).awaitSingle()
/**
@@ -54,7 +54,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.randomKeyAndAwait(): K? =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.randomKeyAndAwait(): K? =
randomKey().awaitFirstOrNull()
/**
@@ -63,7 +63,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.renameAndAwait(oldKey: K, newKey: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.renameAndAwait(oldKey: K, newKey: K): Boolean =
rename(oldKey, newKey).awaitSingle()
/**
@@ -72,7 +72,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.renameIfAbsentAndAwait(oldKey: K, newKey: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.renameIfAbsentAndAwait(oldKey: K, newKey: K): Boolean =
renameIfAbsent(oldKey, newKey).awaitSingle()
/**
@@ -81,7 +81,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.deleteAndAwait(vararg key: K): Long =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.deleteAndAwait(vararg key: K): Long =
delete(*key).awaitSingle()
/**
@@ -90,7 +90,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.unlinkAndAwait(vararg key: K): Long =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.unlinkAndAwait(vararg key: K): Long =
unlink(*key).awaitSingle()
/**
@@ -99,7 +99,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.expireAndAwait(key: K, timeout: Duration): Boolean =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.expireAndAwait(key: K, timeout: Duration): Boolean =
expire(key, timeout).awaitSingle()
/**
@@ -108,7 +108,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.expireAtAndAwait(key: K, expireAt: Instant): Boolean = expireAt(key, expireAt).awaitSingle()
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.expireAtAndAwait(key: K, expireAt: Instant): Boolean = expireAt(key, expireAt).awaitSingle()
/**
@@ -117,7 +117,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.persistAndAwait(key: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.persistAndAwait(key: K): Boolean =
persist(key).awaitSingle()
/**
@@ -126,7 +126,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.moveAndAwait(key: K, dbIndex: Int): Boolean = move(key, dbIndex).awaitSingle()
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.moveAndAwait(key: K, dbIndex: Int): Boolean = move(key, dbIndex).awaitSingle()
/**
* Coroutines variant of [ReactiveRedisOperations.getExpire].
@@ -134,4 +134,4 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveRedisOperations<K, V>.getExpireAndAwait(key: K): Duration? = getExpire(key).awaitFirstOrNull()
suspend fun <K : Any, V : Any> ReactiveRedisOperations<K, V>.getExpireAndAwait(key: K): Duration? = getExpire(key).awaitFirstOrNull()

28
src/main/kotlin/org/springframework/data/redis/core/ReactiveSetOperationsExtensions.kt
View File

@@ -24,7 +24,7 @@ import kotlinx.coroutines.reactive.awaitSingle
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.addAndAwait(key: K, vararg values: V): Long =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.addAndAwait(key: K, vararg values: V): Long =
add(key, *values).awaitSingle()
/**
@@ -33,7 +33,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.removeAndAwait(key: K, vararg values: V): Long =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.removeAndAwait(key: K, vararg values: V): Long =
remove(key, *values).awaitSingle()
/**
@@ -42,7 +42,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.popAndAwait(key: K): V? =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.popAndAwait(key: K): V? =
pop(key).awaitFirstOrNull()
/**
@@ -51,7 +51,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.moveAndAwait(sourceKey: K, value: V, destKey: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.moveAndAwait(sourceKey: K, value: V, destKey: K): Boolean =
move(sourceKey, value, destKey).awaitSingle()
/**
@@ -60,7 +60,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.sizeAndAwait(key: K): Long =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.sizeAndAwait(key: K): Long =
size(key).awaitSingle()
/**
@@ -69,7 +69,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.isMemberAndAwait(key: K, value: V): Boolean =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.isMemberAndAwait(key: K, value: V): Boolean =
isMember(key, value).awaitSingle()
/**
@@ -78,7 +78,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
intersectAndStore(key, otherKey, destKey).awaitSingle()
/**
@@ -87,7 +87,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.intersectAndStoreAndAwait(keys: Collection<K>, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.intersectAndStoreAndAwait(keys: Collection<K>, destKey: K): Long =
intersectAndStore(keys, destKey).awaitSingle()
/**
@@ -96,7 +96,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
unionAndStore(key, otherKey, destKey).awaitSingle()
/**
@@ -105,7 +105,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.unionAndStoreAndAwait(keys: Collection<K>, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.unionAndStoreAndAwait(keys: Collection<K>, destKey: K): Long =
unionAndStore(keys, destKey).awaitSingle()
/**
@@ -114,7 +114,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.differenceAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.differenceAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
differenceAndStore(key, otherKey, destKey).awaitSingle()
/**
@@ -123,7 +123,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.differenceAndStoreAndAwait(keys: Collection<K>, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.differenceAndStoreAndAwait(keys: Collection<K>, destKey: K): Long =
differenceAndStore(keys, destKey).awaitSingle()
/**
@@ -132,7 +132,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.randomMemberAndAwait(key: K): V? =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.randomMemberAndAwait(key: K): V? =
randomMember(key).awaitFirstOrNull()
/**
@@ -141,7 +141,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveSetOperations<K, V>.deleteAndAwait(key: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveSetOperations<K, V>.deleteAndAwait(key: K): Boolean =
delete(key).awaitSingle()

28
src/main/kotlin/org/springframework/data/redis/core/ReactiveStreamOperationsExtensions.kt
View File

@@ -24,7 +24,7 @@ import org.springframework.data.redis.connection.stream.*
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.acknowledgeAndAwait(key: K, group: String, vararg recordIds: String): Long =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.acknowledgeAndAwait(key: K, group: String, vararg recordIds: String): Long =
acknowledge(key, group, *recordIds).awaitSingle()
/**
@@ -33,7 +33,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.acknowledgeAndAwait(key: K, group: String, vararg recordIds: RecordId): Long =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.acknowledgeAndAwait(key: K, group: String, vararg recordIds: RecordId): Long =
acknowledge(key, group, *recordIds).awaitSingle()
/**
@@ -42,7 +42,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.acknowledgeAndAwait(group: String, record: Record<K, *>): Long =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.acknowledgeAndAwait(group: String, record: Record<K, *>): Long =
acknowledge(group, record).awaitSingle()
/**
@@ -51,7 +51,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.addAndAwait(record: MapRecord<K, HK, HV>): RecordId =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.addAndAwait(record: MapRecord<K, HK, HV>): RecordId =
add(record).awaitSingle()
/**
@@ -60,7 +60,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.addAndAwait(record: Record<K, *>): RecordId =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.addAndAwait(record: Record<K, *>): RecordId =
add(record).awaitSingle()
/**
@@ -69,7 +69,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.deleteAndAwait(key: K, vararg recordIds: String): Long =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.deleteAndAwait(key: K, vararg recordIds: String): Long =
delete(key, *recordIds).awaitSingle()
/**
@@ -78,7 +78,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.deleteAndAwait(record: Record<K, *>): Long =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.deleteAndAwait(record: Record<K, *>): Long =
delete(record).awaitSingle()
/**
@@ -87,7 +87,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.deleteAndAwait(key: K, vararg recordIds: RecordId): Long =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.deleteAndAwait(key: K, vararg recordIds: RecordId): Long =
delete(key, *recordIds).awaitSingle()
/**
@@ -96,7 +96,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.createGroupAndAwait(key: K, group: String): String =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.createGroupAndAwait(key: K, group: String): String =
createGroup(key, group).awaitSingle()
/**
@@ -105,7 +105,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.createGroupAndAwait(key: K, readOffset: ReadOffset, group: String): String =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.createGroupAndAwait(key: K, readOffset: ReadOffset, group: String): String =
createGroup(key, readOffset, group).awaitSingle()
/**
@@ -114,7 +114,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.deleteConsumerAndAwait(key: K, consumer: Consumer): String =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.deleteConsumerAndAwait(key: K, consumer: Consumer): String =
deleteConsumer(key, consumer).awaitSingle()
/**
@@ -123,7 +123,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.destroyGroupAndAwait(key: K, group: String): String =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.destroyGroupAndAwait(key: K, group: String): String =
destroyGroup(key, group).awaitSingle()
/**
@@ -132,7 +132,7 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.sizeAndAwait(key: K): Long =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.sizeAndAwait(key: K): Long =
size(key).awaitSingle()
/**
@@ -141,5 +141,5 @@ suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> Reactiv
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified HK : Any, reified HV : Any> ReactiveStreamOperations<K, HK, HV>.trimAndAwait(key: K, count: Long): Long =
suspend fun <K : Any, HK : Any, HV : Any> ReactiveStreamOperations<K, HK, HV>.trimAndAwait(key: K, count: Long): Long =
trim(key, count).awaitSingle()

50
src/main/kotlin/org/springframework/data/redis/core/ReactiveValueOperationsExtensions.kt
View File

@@ -26,7 +26,7 @@ import java.time.Duration
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.setAndAwait(key: K, value: V): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.setAndAwait(key: K, value: V): Boolean =
set(key, value).awaitSingle()
/**
@@ -35,7 +35,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.setAndAwait(key: K, value: V, timeout: Duration): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.setAndAwait(key: K, value: V, timeout: Duration): Boolean =
set(key, value, timeout).awaitSingle()
/**
@@ -44,7 +44,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.setIfAbsentAndAwait(key: K, value: V): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.setIfAbsentAndAwait(key: K, value: V): Boolean =
setIfAbsent(key, value).awaitSingle()
/**
@@ -53,7 +53,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.setIfAbsentAndAwait(key: K, value: V, timeout: Duration): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.setIfAbsentAndAwait(key: K, value: V, timeout: Duration): Boolean =
setIfAbsent(key, value, timeout).awaitSingle()
/**
@@ -62,7 +62,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.setIfPresentAndAwait(key: K, value: V): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.setIfPresentAndAwait(key: K, value: V): Boolean =
setIfPresent(key, value).awaitSingle()
/**
@@ -71,7 +71,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.setIfPresentAndAwait(key: K, value: V, timeout: Duration): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.setIfPresentAndAwait(key: K, value: V, timeout: Duration): Boolean =
setIfPresent(key, value, timeout).awaitSingle()
/**
@@ -80,7 +80,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.multiSetAndAwait(map: Map<K, V>): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.multiSetAndAwait(map: Map<K, V>): Boolean =
multiSet(map).awaitSingle()
/**
@@ -89,7 +89,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.multiSetIfAbsentAndAwait(map: Map<K, V>): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.multiSetIfAbsentAndAwait(map: Map<K, V>): Boolean =
multiSetIfAbsent(map).awaitSingle()
/**
@@ -98,7 +98,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.getAndAwait(key: K): V? =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.getAndAwait(key: K): V? =
get(key).awaitFirstOrNull()
/**
@@ -108,7 +108,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Christoph Strobl
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.getAndSetAndAwait(key: K, value: V): V? =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.getAndSetAndAwait(key: K, value: V): V? =
getAndSet(key, value).awaitFirstOrNull()
/**
@@ -117,7 +117,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.multiGetAndAwait(vararg keys: K): List<V?> =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.multiGetAndAwait(vararg keys: K): List<V?> =
multiGet(keys.toCollection(ArrayList())).awaitSingle()
/**
@@ -126,7 +126,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.multiGetAndAwait(keys: Collection<K>): List<V?> =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.multiGetAndAwait(keys: Collection<K>): List<V?> =
multiGet(keys).awaitSingle()
/**
@@ -135,7 +135,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.incrementAndAwait(key: K): Long =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.incrementAndAwait(key: K): Long =
increment(key).awaitSingle()
/**
@@ -144,7 +144,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.incrementAndAwait(key: K, delta: Long): Long =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.incrementAndAwait(key: K, delta: Long): Long =
increment(key, delta).awaitSingle()
/**
@@ -153,7 +153,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.incrementAndAwait(key: K, delta: Double): Double =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.incrementAndAwait(key: K, delta: Double): Double =
increment(key, delta).awaitSingle()
/**
@@ -162,7 +162,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.decrementAndAwait(key: K): Long =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.decrementAndAwait(key: K): Long =
decrement(key).awaitSingle()
/**
@@ -171,7 +171,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.decrementAndAwait(key: K, delta: Long): Long =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.decrementAndAwait(key: K, delta: Long): Long =
decrement(key, delta).awaitSingle()
/**
@@ -180,7 +180,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.appendAndAwait(key: K, value: String): Long =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.appendAndAwait(key: K, value: String): Long =
append(key, value).awaitSingle()
/**
@@ -189,7 +189,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.getAndAwait(key: K, start: Long, end: Long): String? =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.getAndAwait(key: K, start: Long, end: Long): String? =
get(key, start, end).awaitFirstOrNull()
/**
@@ -198,7 +198,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.setAndAwait(key: K, value: V, offset: Long): Long =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.setAndAwait(key: K, value: V, offset: Long): Long =
set(key, value, offset).awaitSingle()
/**
@@ -208,7 +208,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Christoph Strobl
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.sizeAndAwait(key: K): Long =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.sizeAndAwait(key: K): Long =
size(key).awaitSingle()
/**
@@ -217,7 +217,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.setBitAndAwait(key: K, offset: Long, value: Boolean): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.setBitAndAwait(key: K, offset: Long, value: Boolean): Boolean =
setBit(key, offset, value).awaitSingle()
/**
@@ -226,7 +226,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.getBitAndAwait(key: K, offset: Long): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.getBitAndAwait(key: K, offset: Long): Boolean =
getBit(key, offset).awaitSingle()
/**
@@ -235,7 +235,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.bitFieldAndAwait(key: K, commands: BitFieldSubCommands): List<Long?> =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.bitFieldAndAwait(key: K, commands: BitFieldSubCommands): List<Long?> =
bitField(key, commands).awaitSingle()
/**
@@ -244,5 +244,5 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveValueOperations<K, V>.deleteAndAwait(key: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveValueOperations<K, V>.deleteAndAwait(key: K): Boolean =
delete(key).awaitSingle()

38
src/main/kotlin/org/springframework/data/redis/core/ReactiveZSetOperationsExtensions.kt
View File

@@ -26,7 +26,7 @@ import org.springframework.data.redis.connection.RedisZSetCommands
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.addAndAwait(key: K, value: V, score: Double): Boolean =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.addAndAwait(key: K, value: V, score: Double): Boolean =
add(key, value, score).awaitSingle()
/**
@@ -35,7 +35,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.addAllAndAwait(key: K, values: Collection<ZSetOperations.TypedTuple<V>>): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.addAllAndAwait(key: K, values: Collection<ZSetOperations.TypedTuple<V>>): Long =
addAll(key, values).awaitSingle()
/**
@@ -44,7 +44,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.removeAndAwait(key: K, vararg values: Any): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.removeAndAwait(key: K, vararg values: Any): Long =
remove(key, *values).awaitSingle()
/**
@@ -53,7 +53,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.incrementScoreAndAwait(key: K, value: V, score: Double): Double =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.incrementScoreAndAwait(key: K, value: V, score: Double): Double =
incrementScore(key, value, score).awaitSingle()
/**
@@ -62,7 +62,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.rankAndAwait(key: K, value: V): Long? =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.rankAndAwait(key: K, value: V): Long? =
rank(key, value).awaitFirstOrNull()
/**
@@ -71,7 +71,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.reverseRankAndAwait(key: K, value: V): Long? =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.reverseRankAndAwait(key: K, value: V): Long? =
reverseRank(key, value).awaitFirstOrNull()
/**
@@ -80,7 +80,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.countAndAwait(key: K, range: Range<Double>): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.countAndAwait(key: K, range: Range<Double>): Long =
count(key, range).awaitSingle()
/**
@@ -89,7 +89,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.scoreAndAwait(key: K, value: V): Double? =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.scoreAndAwait(key: K, value: V): Double? =
score(key, value).awaitFirstOrNull()
/**
@@ -98,7 +98,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.removeRangeAndAwait(key: K, range: Range<Long>): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.removeRangeAndAwait(key: K, range: Range<Long>): Long =
removeRange(key, range).awaitSingle()
/**
@@ -107,7 +107,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.removeRangeByScoreAndAwait(key: K, range: Range<Double>): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.removeRangeByScoreAndAwait(key: K, range: Range<Double>): Long =
removeRangeByScore(key, range).awaitSingle()
/**
@@ -116,7 +116,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
unionAndStore(key, otherKey, destKey).awaitSingle()
/**
@@ -125,7 +125,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K): Long =
unionAndStore(key, otherKeys, destKey).awaitSingle()
/**
@@ -134,7 +134,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K, aggregate: RedisZSetCommands.Aggregate): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K, aggregate: RedisZSetCommands.Aggregate): Long =
unionAndStore(key, otherKeys, destKey, aggregate).awaitSingle()
/**
@@ -143,7 +143,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K, aggregate: RedisZSetCommands.Aggregate, weights: RedisZSetCommands.Weights): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.unionAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K, aggregate: RedisZSetCommands.Aggregate, weights: RedisZSetCommands.Weights): Long =
unionAndStore(key, otherKeys, destKey, aggregate, weights).awaitSingle()
/**
@@ -152,7 +152,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKey: K, destKey: K): Long =
intersectAndStore(key, otherKey, destKey).awaitSingle()
/**
@@ -161,7 +161,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K): Long =
intersectAndStore(key, otherKeys, destKey).awaitSingle()
/**
@@ -170,7 +170,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K, aggregate: RedisZSetCommands.Aggregate): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K, aggregate: RedisZSetCommands.Aggregate): Long =
intersectAndStore(key, otherKeys, destKey, aggregate).awaitSingle()
/**
@@ -179,7 +179,7 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K, aggregate: RedisZSetCommands.Aggregate, weights: RedisZSetCommands.Weights): Long =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.intersectAndStoreAndAwait(key: K, otherKeys: Collection<K>, destKey: K, aggregate: RedisZSetCommands.Aggregate, weights: RedisZSetCommands.Weights): Long =
intersectAndStore(key, otherKeys, destKey, aggregate, weights).awaitSingle()
/**
@@ -188,5 +188,5 @@ suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K,
* @author Mark Paluch
* @since 2.2
*/
suspend inline fun <reified K : Any, reified V : Any> ReactiveZSetOperations<K, V>.deleteAndAwait(key: K): Boolean =
suspend fun <K : Any, V : Any> ReactiveZSetOperations<K, V>.deleteAndAwait(key: K): Boolean =
delete(key).awaitSingle()