public interface ReactiveSetOperations<K,V>
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Long> |
add(K key,
V... values)
Add given
values to set at key . |
reactor.core.publisher.Mono<Boolean> |
delete(K key)
Removes the given key.
|
reactor.core.publisher.Flux<V> |
difference(Collection<K> keys)
Diff all sets for given
keys . |
reactor.core.publisher.Flux<V> |
difference(K key,
Collection<K> otherKeys)
Diff all sets for given
key and otherKeys . |
reactor.core.publisher.Flux<V> |
difference(K key,
K otherKey)
Diff all sets for given
key and otherKey . |
reactor.core.publisher.Mono<Long> |
differenceAndStore(Collection<K> keys,
K destKey)
Diff all sets for given
keys and store result in destKey . |
reactor.core.publisher.Mono<Long> |
differenceAndStore(K key,
Collection<K> otherKeys,
K destKey)
Diff all sets for given
key and otherKeys and store result in destKey . |
reactor.core.publisher.Mono<Long> |
differenceAndStore(K key,
K otherKey,
K destKey)
Diff all sets for given
key and otherKey and store result in destKey . |
reactor.core.publisher.Flux<V> |
distinctRandomMembers(K key,
long count)
Get
count distinct random elements from set at key . |
reactor.core.publisher.Flux<V> |
intersect(Collection<K> keys)
Returns the members intersecting all given sets at
keys . |
reactor.core.publisher.Flux<V> |
intersect(K key,
Collection<K> otherKeys)
Returns the members intersecting all given sets at
key and otherKeys . |
reactor.core.publisher.Flux<V> |
intersect(K key,
K otherKey)
Returns the members intersecting all given sets at
key and otherKey . |
reactor.core.publisher.Mono<Long> |
intersectAndStore(Collection<K> keys,
K destKey)
Intersect all given sets at
keys and store result in destKey . |
reactor.core.publisher.Mono<Long> |
intersectAndStore(K key,
Collection<K> otherKeys,
K destKey)
Intersect all given sets at
key and otherKeys and store result in destKey . |
reactor.core.publisher.Mono<Long> |
intersectAndStore(K key,
K otherKey,
K destKey)
Intersect all given sets at
key and otherKey and store result in destKey . |
reactor.core.publisher.Mono<Map<Object,Boolean>> |
isMember(K key,
Object... objects)
Check if set at
key contains one or more values . |
reactor.core.publisher.Mono<Boolean> |
isMember(K key,
Object o)
Check if set at
key contains value . |
reactor.core.publisher.Flux<V> |
members(K key)
Get all elements of set at
key . |
reactor.core.publisher.Mono<Boolean> |
move(K sourceKey,
V value,
K destKey)
Move
value from key to destKey |
reactor.core.publisher.Mono<V> |
pop(K key)
Remove and return a random member from set at
key . |
reactor.core.publisher.Flux<V> |
pop(K key,
long count)
Remove and return
count random members from set at key . |
reactor.core.publisher.Mono<V> |
randomMember(K key)
Get random element from set at
key . |
reactor.core.publisher.Flux<V> |
randomMembers(K key,
long count)
Get
count random elements from set at key . |
reactor.core.publisher.Mono<Long> |
remove(K key,
Object... values)
Remove given
values from set at key and return the number of removed elements. |
default reactor.core.publisher.Flux<V> |
scan(K key)
Use a
Flux to iterate over entries in the set at key . |
reactor.core.publisher.Flux<V> |
scan(K key,
ScanOptions options)
|
reactor.core.publisher.Mono<Long> |
size(K key)
Get size of set at
key . |
reactor.core.publisher.Flux<V> |
union(Collection<K> keys)
Union all sets at given
keys . |
reactor.core.publisher.Flux<V> |
union(K key,
Collection<K> otherKeys)
Union all sets at given
keys and otherKeys . |
reactor.core.publisher.Flux<V> |
union(K key,
K otherKey)
Union all sets at given
keys and otherKey . |
reactor.core.publisher.Mono<Long> |
unionAndStore(Collection<K> keys,
K destKey)
Union all sets at given
keys and store result in destKey . |
reactor.core.publisher.Mono<Long> |
unionAndStore(K key,
Collection<K> otherKeys,
K destKey)
Union all sets at given
key and otherKeys and store result in destKey . |
reactor.core.publisher.Mono<Long> |
unionAndStore(K key,
K otherKey,
K destKey)
Union all sets at given
key and otherKey and store result in destKey . |
reactor.core.publisher.Mono<Long> add(K key, V... values)
values
to set at key
.key
- must not be null.values
- reactor.core.publisher.Mono<Long> remove(K key, Object... values)
values
from set at key
and return the number of removed elements.key
- must not be null.values
- reactor.core.publisher.Mono<V> pop(K key)
key
.key
- must not be null.reactor.core.publisher.Flux<V> pop(K key, long count)
count
random members from set at key
.key
- must not be null.count
- number of random members to pop from the set.Flux
emitting random members.reactor.core.publisher.Mono<Boolean> move(K sourceKey, V value, K destKey)
value
from key
to destKey
sourceKey
- must not be null.value
- destKey
- must not be null.reactor.core.publisher.Mono<Long> size(K key)
key
.key
- must not be null.reactor.core.publisher.Mono<Boolean> isMember(K key, Object o)
key
contains value
.key
- must not be null.o
- reactor.core.publisher.Mono<Map<Object,Boolean>> isMember(K key, Object... objects)
key
contains one or more values
.key
- must not be null.objects
- reactor.core.publisher.Flux<V> intersect(K key, K otherKey)
key
and otherKey
.key
- must not be null.otherKey
- must not be null.reactor.core.publisher.Flux<V> intersect(K key, Collection<K> otherKeys)
key
and otherKeys
.key
- must not be null.otherKeys
- must not be null.reactor.core.publisher.Flux<V> intersect(Collection<K> keys)
keys
.keys
- must not be null.reactor.core.publisher.Mono<Long> intersectAndStore(K key, K otherKey, K destKey)
key
and otherKey
and store result in destKey
.key
- must not be null.otherKey
- must not be null.destKey
- must not be null.reactor.core.publisher.Mono<Long> intersectAndStore(K key, Collection<K> otherKeys, K destKey)
key
and otherKeys
and store result in destKey
.key
- must not be null.otherKeys
- must not be null.destKey
- must not be null.reactor.core.publisher.Mono<Long> intersectAndStore(Collection<K> keys, K destKey)
keys
and store result in destKey
.keys
- must not be null.destKey
- must not be null.reactor.core.publisher.Flux<V> union(K key, K otherKey)
keys
and otherKey
.key
- must not be null.otherKey
- must not be null.reactor.core.publisher.Flux<V> union(K key, Collection<K> otherKeys)
keys
and otherKeys
.key
- must not be null.otherKeys
- must not be null.reactor.core.publisher.Flux<V> union(Collection<K> keys)
keys
.keys
- must not be null.reactor.core.publisher.Mono<Long> unionAndStore(K key, K otherKey, K destKey)
key
and otherKey
and store result in destKey
.key
- must not be null.otherKey
- must not be null.destKey
- must not be null.reactor.core.publisher.Mono<Long> unionAndStore(K key, Collection<K> otherKeys, K destKey)
key
and otherKeys
and store result in destKey
.key
- must not be null.otherKeys
- must not be null.destKey
- must not be null.reactor.core.publisher.Mono<Long> unionAndStore(Collection<K> keys, K destKey)
keys
and store result in destKey
.keys
- must not be null.destKey
- must not be null.reactor.core.publisher.Flux<V> difference(K key, K otherKey)
key
and otherKey
.key
- must not be null.otherKey
- must not be null.reactor.core.publisher.Flux<V> difference(K key, Collection<K> otherKeys)
key
and otherKeys
.key
- must not be null.otherKeys
- must not be null.reactor.core.publisher.Flux<V> difference(Collection<K> keys)
keys
.keys
- must not be null.reactor.core.publisher.Mono<Long> differenceAndStore(K key, K otherKey, K destKey)
key
and otherKey
and store result in destKey
.key
- must not be null.otherKey
- must not be null.destKey
- must not be null.reactor.core.publisher.Mono<Long> differenceAndStore(K key, Collection<K> otherKeys, K destKey)
key
and otherKeys
and store result in destKey
.key
- must not be null.otherKeys
- must not be null.destKey
- must not be null.reactor.core.publisher.Mono<Long> differenceAndStore(Collection<K> keys, K destKey)
keys
and store result in destKey
.keys
- must not be null.destKey
- must not be null.reactor.core.publisher.Flux<V> members(K key)
key
.key
- must not be null.default reactor.core.publisher.Flux<V> scan(K key)
Flux
to iterate over entries in the set at key
. The resulting Flux
acts as a cursor
and issues SSCAN
commands itself as long as the subscriber signals demand.key
- must not be null.Flux
emitting the values one by one or an empty Flux
if none
exist.IllegalArgumentException
- when given key
is null.reactor.core.publisher.Flux<V> scan(K key, ScanOptions options)
Flux
to iterate over entries in the set at key
given ScanOptions
. The resulting
Flux
acts as a cursor and issues SSCAN
commands itself as long as the subscriber signals demand.key
- must not be null.options
- must not be null. Use ScanOptions.NONE
instead.Flux
emitting the values one by one or an empty Flux
if the key
does not exist.IllegalArgumentException
- when one of the required arguments is null.reactor.core.publisher.Mono<V> randomMember(K key)
key
.key
- must not be null.reactor.core.publisher.Flux<V> distinctRandomMembers(K key, long count)
count
distinct random elements from set at key
.key
- must not be null.count
- number of members to return.reactor.core.publisher.Flux<V> randomMembers(K key, long count)
count
random elements from set at key
.key
- must not be null.count
- number of members to return.Copyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.