V
- The value type, these follow
JavaBean conventions.public interface LongObjStore<V extends Serializable> extends Store<Long,V>
Store
Modifier and Type | Method and Description |
---|---|
Mono<Void> |
delete(long id)
Deletes a value associated with the provided id.
|
default Mono<Void> |
delete(Long id)
Deletes a value associated with the provided id.
|
Mono<Void> |
delete(Publisher<Long> ids)
Deletes the values associated with the provided ids.
|
Mono<Void> |
deleteInRange(long start,
long end)
Deletes values within a range of ids.
|
default Mono<Void> |
deleteInRange(Long start,
Long end)
Deletes values within a range of ids.
|
default Flux<Tuple2<Long,V>> |
entries()
Gets a stream of all entries in the data source.
|
Mono<V> |
find(long id)
Attempts to find the value associated with the provided id.
|
default Mono<V> |
find(Long id)
Attempts to find the value associated with the provided id.
|
Flux<V> |
findInRange(long start,
long end)
Retrieves all stored values with ids within a provided range.
|
default Flux<V> |
findInRange(Long start,
Long end)
Retrieves all stored values with ids within a provided range.
|
default Flux<LongObjTuple2<V>> |
longObjEntries()
Gets a stream of all entries in the data source.
|
default Mono<Void> |
save(Long key,
V value)
Stores a key value pair.
|
default Mono<Void> |
save(Publisher<Tuple2<Long,V>> entryStream)
Stores key value pairs.
|
Mono<Void> |
saveWithLong(long key,
V value)
Stores a key value pair.
|
Mono<Void> |
saveWithLong(Publisher<LongObjTuple2<V>> entryStream)
Stores key value pairs.
|
default Mono<Void> save(Long key, V value)
Store
save
in interface Store<Long,V extends Serializable>
key
- The key representing the value.value
- The value.Mono<Void> saveWithLong(long key, V value)
key
- The key representing the value.value
- The value.default Mono<Void> save(Publisher<Tuple2<Long,V>> entryStream)
Store
save
in interface Store<Long,V extends Serializable>
entryStream
- A flux providing the key value pairs.Mono<Void> saveWithLong(Publisher<LongObjTuple2<V>> entryStream)
entryStream
- A flux providing the key value pairs.default Mono<V> find(Long id)
Store
find
in interface Store<Long,V extends Serializable>
id
- The id to search with.Mono<V> find(long id)
id
- The id to search with.default Flux<V> findInRange(Long start, Long end)
Store
findInRange
in interface Store<Long,V extends Serializable>
start
- The starting key (inclusive).end
- The ending key (exclusive).Flux<V> findInRange(long start, long end)
start
- The starting key (inclusive).end
- The ending key (exclusive).default Mono<Void> delete(Long id)
Store
delete
in interface Store<Long,V extends Serializable>
id
- The id of the value to delete.Mono<Void> delete(long id)
id
- The id of the value to delete.Mono<Void> delete(Publisher<Long> ids)
Store
delete
in interface Store<Long,V extends Serializable>
ids
- A stream of ids to delete values for.default Mono<Void> deleteInRange(Long start, Long end)
Store
deleteInRange
in interface Store<Long,V extends Serializable>
start
- The starting key (inclusive).end
- The ending key (exclusive).Mono<Void> deleteInRange(long start, long end)
start
- The starting key (inclusive).end
- The ending key (exclusive).default Flux<Tuple2<Long,V>> entries()
Store
entries
in interface Store<Long,V extends Serializable>
default Flux<LongObjTuple2<V>> longObjEntries()