[infinispan-issues] [JBoss JIRA] (ISPN-9923) Provide a reactive key value store API
[
https://issues.jboss.org/browse/ISPN-9923?page=com.atlassian.jira.plugin....
]
Katia Aresti updated ISPN-9923:
-------------------------------
Description:
Create a first *ReactiveCache* api based in reactive streams standard. The example API
below is not complete, is just an example
{code:java}
public interface ReactiveKeyValueStore<K, V> {
CompletionStage<V> get(K key);
CompletionStage<Void> put(K key, V value);
CompletionStage<V> getAndPut(K key, V value);
CompletionStage<Void> remove(K key);
CompletionStage<Boolean> remove(K key, V value);
CompletionStage<V> getAndRemove(K key);
CompletionStage<Void> putMany(Publisher<Entry<K, V>> pairs);
Publisher<Entry<K, V>> entries();
...
}
{code}
was:
Create a first *ReactiveCache* api based in reactive streams standard. The example API
below is not complete, is just an example
{code:java}
public interface ReactiveCache<K, V> {
CompletionStage<V> get(K key);
CompletionStage<Void> put(K key, V value);
CompletionStage<V> getAndPut(K key, V value);
CompletionStage<Void> remove(K key);
CompletionStage<Boolean> remove(K key, V value);
CompletionStage<V> getAndRemove(K key);
CompletionStage<Void> putMany(Publisher<Map.Entry<K, V>> pairs);
Publisher<K> getKeys();
Publisher<V> getValues();
CompletionStage<Long> size();
}
{code}
Provide a reactive key value store API
--------------------------------------
Key: ISPN-9923
URL: https://issues.jboss.org/browse/ISPN-9923
Project: Infinispan
Issue Type: Sub-task
Components: API
Reporter: Katia Aresti
Assignee: Katia Aresti
Priority: Major
Create a first *ReactiveCache* api based in reactive streams standard. The example API
below is not complete, is just an example
{code:java}
public interface ReactiveKeyValueStore<K, V> {
CompletionStage<V> get(K key);
CompletionStage<Void> put(K key, V value);
CompletionStage<V> getAndPut(K key, V value);
CompletionStage<Void> remove(K key);
CompletionStage<Boolean> remove(K key, V value);
CompletionStage<V> getAndRemove(K key);
CompletionStage<Void> putMany(Publisher<Entry<K, V>> pairs);
Publisher<Entry<K, V>> entries();
...
}
{code}
--
This message was sent by Atlassian Jira
(v7.12.1#712002)